fixing lint

Author: tcnichol

backend/app/dependencies.py

@@ -93,7 +93,9 @@ async def get_rabbitmq() -> AbstractChannel:
 def get_blocking_rabbitmq() -> BlockingChannel:
     """Legacy blocking RabbitMQ client (for extractors that need it)"""
     credentials = pika.PlainCredentials(settings.RABBITMQ_USER, settings.RABBITMQ_PASS)
-    parameters = pika.ConnectionParameters(settings.RABBITMQ_HOST, credentials=credentials)
+    parameters = pika.ConnectionParameters(
+        settings.RABBITMQ_HOST, credentials=credentials
+    )
     connection = pika.BlockingConnection(parameters)
     return connection.channel()
 

backend/app/rabbitmq/listeners.py

@@ -22,11 +22,15 @@
 
 
 async def create_reply_queue(channel: AbstractChannel):
-    if (config_entry := await ConfigEntryDB.find_one({"key": "instance_id"})) is not None:
+    if (
+        config_entry := await ConfigEntryDB.find_one({"key": "instance_id"})
+    ) is not None:
         instance_id = config_entry.value
     else:
         instance_id = "".join(
-            random.choice(string.ascii_uppercase + string.ascii_lowercase + string.digits)
+            random.choice(
+                string.ascii_uppercase + string.ascii_lowercase + string.digits
+            )
             for _ in range(10)
         )
         config_entry = ConfigEntryDB(key="instance_id", value=instance_id)
@@ -36,7 +40,9 @@ async def create_reply_queue(channel: AbstractChannel):
 
     # Use aio_pika methods instead of pika methods
     exchange = await channel.declare_exchange("clowder", durable=True)
-    queue = await channel.declare_queue(queue_name, durable=True, exclusive=False, auto_delete=False)
+    queue = await channel.declare_queue(
+        queue_name, durable=True, exclusive=False, auto_delete=False
+    )
     await queue.bind(exchange)
 
     return queue.name
@@ -61,7 +67,6 @@ async def submit_file_job(
     )
     await job.insert()
 
-
     current_secretKey = await get_user_job_key(user.email)
     msg_body = EventListenerJobMessage(
         filename=file_out.name,
@@ -79,7 +84,7 @@ async def submit_file_job(
     print("RABBITMQ_CLIENT: " + str(rabbitmq_client))
     await rabbitmq_client.default_exchange.publish(
         aio_pika.Message(
-            body=json.dumps(msg_body.dict(), ensure_ascii=False).encode('utf-8'),
+            body=json.dumps(msg_body.dict(), ensure_ascii=False).encode("utf-8"),
             content_type="application/json",
             delivery_mode=aio_pika.DeliveryMode.PERSISTENT,
             reply_to=reply_to,
@@ -117,7 +122,7 @@ async def submit_dataset_job(
     reply_to = await create_reply_queue(rabbitmq_client)
     await rabbitmq_client.default_exchange.publish(
         aio_pika.Message(
-            body=json.dumps(msg_body.dict(), ensure_ascii=False).encode('utf-8'),
+            body=json.dumps(msg_body.dict(), ensure_ascii=False).encode("utf-8"),
             content_type="application/json",
             delivery_mode=aio_pika.DeliveryMode.PERSISTENT,
             reply_to=reply_to,

backend/app/routers/files.py

@@ -41,6 +41,7 @@
 router = APIRouter()
 security = HTTPBearer()
 
+
 class CustomJSONEncoder(JSONEncoder):
     def default(self, obj):
         if isinstance(obj, PydanticObjectId):
@@ -148,13 +149,12 @@ async def add_file_entry(
 
     # Publish a message when indexing is complete
 
-
     # FIXED: Use aio_pika publishing
     message_body = {
         "event_type": "file_indexed",
         "file_data": json.loads(new_file.json()),
         "user": json.loads(user.json()),
-        "timestamp": datetime.now().isoformat()
+        "timestamp": datetime.now().isoformat(),
     }
 
     # Get the exchange first
@@ -163,7 +163,7 @@ async def add_file_entry(
     # Use aio_pika publish method
     await exchange.publish(
         aio_pika.Message(
-            body=json.dumps(message_body).encode('utf-8'),
+            body=json.dumps(message_body).encode("utf-8"),
             content_type="application/json",
             delivery_mode=aio_pika.DeliveryMode.PERSISTENT,
         ),
@@ -201,7 +201,7 @@ async def add_local_file_entry(
         "event_type": "file_indexed",
         "file_data": json.loads(new_file.json()),
         "user": json.loads(user.json()),
-        "timestamp": datetime.now().isoformat()
+        "timestamp": datetime.now().isoformat(),
     }
 
     # Get the exchange first
@@ -210,7 +210,7 @@ async def add_local_file_entry(
     # Use aio_pika publish method
     await exchange.publish(
         aio_pika.Message(
-            body=json.dumps(message_body).encode('utf-8'),
+            body=json.dumps(message_body).encode("utf-8"),
             content_type="application/json",
             delivery_mode=aio_pika.DeliveryMode.PERSISTENT,
         ),