chore: fix black after plate team changes

HumanSignal · Jun 24, 2024 · a1a0db0 · a1a0db0
1 parent a389091
commit a1a0db0
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 3 deletions.
diff --git a/server/tasks/process_file.py b/server/tasks/process_file.py
@@ -25,7 +25,11 @@
 
 REDIS_URL = os.getenv("REDIS_URL", "redis://localhost:6379/0")
 app = Celery(
-    "worker", broker=REDIS_URL, backend=REDIS_URL, accept_content=["json", "pickle"], broker_connection_retry_on_startup=True
+    "worker",
+    broker=REDIS_URL,
+    backend=REDIS_URL,
+    accept_content=["json", "pickle"],
+    broker_connection_retry_on_startup=True,
 )
 
 settings = Settings()

diff --git a/server/utils.py b/server/utils.py
@@ -41,7 +41,9 @@ def ensure_topic(topic_name: str):
     retention_ms = settings.kafka_retention_ms
 
     admin_client = KafkaAdminClient(
-        bootstrap_servers=bootstrap_servers, client_id="topic_creator", api_version=(2, 5, 0)
+        bootstrap_servers=bootstrap_servers,
+        client_id="topic_creator",
+        api_version=(2, 5, 0),
     )
 
     topic = NewTopic(
@@ -63,7 +65,9 @@ def delete_topic(topic_name: str):
     bootstrap_servers = settings.kafka_bootstrap_servers
 
     admin_client = KafkaAdminClient(
-        bootstrap_servers=bootstrap_servers, client_id="topic_deleter", api_version=(2, 5, 0)
+        bootstrap_servers=bootstrap_servers,
+        client_id="topic_deleter",
+        api_version=(2, 5, 0),
     )
 
     admin_client.delete_topics(topics=[topic_name])