Yolo

Author: abrookins

agent_memory_server/dependencies.py

@@ -19,32 +19,14 @@ async def add_task(
         """Run tasks either directly or through Docket"""
         from docket import Docket
 
-        from agent_memory_server.utils.redis import get_redis_conn
-
         logger.info("Adding task to background tasks...")
 
         if settings.use_docket:
             logger.info("Scheduling task through Docket")
-            # Get the Redis connection that's already configured (will use testcontainer in tests)
-            redis_conn = await get_redis_conn()
-
-            # Extract Redis URL from the connection pool
-            connection_kwargs = redis_conn.connection_pool.connection_kwargs
-            if "host" in connection_kwargs and "port" in connection_kwargs:
-                redis_url = (
-                    f"redis://{connection_kwargs['host']}:{connection_kwargs['port']}"
-                )
-                if "db" in connection_kwargs:
-                    redis_url += f"/{connection_kwargs['db']}"
-            else:
-                # Fallback to settings if we can't extract from connection
-                redis_url = settings.redis_url
-
-            logger.info("redis_url: %s", redis_url)
-            logger.info("docket_name: %s", settings.docket_name)
+
             async with Docket(
                 name=settings.docket_name,
-                url=redis_url,
+                url=settings.redis_url,
             ) as docket:
                 # Schedule task through Docket
                 await docket.add(func)(*args, **kwargs)

scripts/tag_and_push_client.py

@@ -78,6 +78,7 @@ def tag_exists(tag_name: str) -> bool:
             ["git", "rev-parse", f"refs/tags/{tag_name}"],
             capture_output=True,
             check=True,
+            stderr=subprocess.DEVNULL,  # Suppress stderr since we expect this to fail for non-existent tags
         )
         return True
     except subprocess.CalledProcessError: