fix: changed autodelete to auto_delete (#107)

nautiluslabsco · Dec 9, 2022 · 7e1b01b · 7e1b01b
1 parent 17f56fa
commit 7e1b01b
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/ergo/amqp_invoker.py b/ergo/amqp_invoker.py
@@ -63,7 +63,7 @@ def __init__(self, invocable: FunctionInvocable) -> None:
         component_queue_name = f"{self._invocable.config.func}".replace("/", ":")
         if component_queue_name.startswith(":"):
             component_queue_name = component_queue_name[1:]
-        self._component_queue = kombu.Queue(name=component_queue_name, exchange=self._exchange, routing_key=str(SubTopic(self._invocable.config.subtopic)), durable=False, autodelete=True)
+        self._component_queue = kombu.Queue(name=component_queue_name, exchange=self._exchange, routing_key=str(SubTopic(self._invocable.config.subtopic)), durable=False, auto_delete=True)
         instance_queue_name = f"{component_queue_name}:{instance_id()}"
         self._instance_queue = kombu.Queue(name=instance_queue_name, exchange=self._exchange, routing_key=str(SubTopic(instance_id())), auto_delete=True)
         error_queue_name = f"{component_queue_name}:error"

diff --git a/ergo/version.py b/ergo/version.py
@@ -7,7 +7,7 @@
 import subprocess
 import sys
 
-VERSION = '0.11.2'
+VERSION = '0.11.3'
 
 
 def get_version() -> str: