From 7e1b01bde0f7d8b35a86e972ecd28e38de2ab208 Mon Sep 17 00:00:00 2001 From: Xian Yi Teng Date: Fri, 9 Dec 2022 10:29:38 -0800 Subject: [PATCH] fix: changed autodelete to auto_delete (#107) --- ergo/amqp_invoker.py | 2 +- ergo/version.py | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/ergo/amqp_invoker.py b/ergo/amqp_invoker.py index 47b5578..7fbb5fd 100644 --- 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 index 1da023b..0c3572d 100644 --- 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: