Fixed invalid type usage in get_rabbit_channel and `close_rabbit_ch…

…annel` (#2280)
minvws · Jan 8, 2024 · d7cb589 · d7cb589
1 parent b359f1c
commit d7cb589
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/octopoes/octopoes/tasks/tasks.py b/octopoes/octopoes/tasks/tasks.py
@@ -32,13 +32,13 @@
 
 @worker_process_shutdown.connect
 def shutdown_worker(**kwargs):
-    close_rabbit_channel(settings.queue_uri)
+    close_rabbit_channel(str(settings.queue_uri))
 
 
 @worker_process_init.connect
 def init_worker(**kwargs):
     """Set up one RabbitMQ connection and channel on worker startup"""
-    get_rabbit_channel(settings.queue_uri)
+    get_rabbit_channel(str(settings.queue_uri))
 
 
 log = get_task_logger(__name__)