implicit single connection

i-dot-ai · Apr 13, 2024 · 4794b8b · 4794b8b
1 parent bfcfd65
commit 4794b8b
Showing 1 changed file with 2 additions and 4 deletions.
diff --git a/core_api/src/routes/file.py b/core_api/src/routes/file.py
@@ -23,7 +23,6 @@
 
 # === Queues ===
 router = RedisRouter(url=env.redis_url)
-publisher = router.publisher(env.ingest_queue_name)
 
 
 # === Storage ===
@@ -54,7 +53,7 @@ async def create_upload_file(name: str, type: str, location: AnyHttpUrl) -> UUID
     Args:
         name (str): The file name to be recorded
         type (str): The file type to be recorded
-        location (AnyHttpUrl): The presigned file resource location
+        location (AnyHttpUrl): The pre-signed file resource location
 
     Returns:
         UUID: The file uuid from the elastic database
@@ -69,8 +68,7 @@ async def create_upload_file(name: str, type: str, location: AnyHttpUrl) -> UUID
     storage_handler.write_item(file)
 
     log.info(f"publishing {file.uuid}")
-    await router.broker.connect()
-    await publisher.publish(file)
+    await router.broker.publish(file, env.ingest_queue_name)
 
     return file.uuid