diff --git a/backend/AnimatedDrawings/application/task/base_task.py b/backend/AnimatedDrawings/application/task/base_task.py index eedcb74b..7ecf18fb 100644 --- a/backend/AnimatedDrawings/application/task/base_task.py +++ b/backend/AnimatedDrawings/application/task/base_task.py @@ -44,13 +44,8 @@ def on_failure(self, exc, task_id, args, kwargs, einfo): type='direct', durable=True) - notification_queue = Queue(name=QueueConfig.NOTIFICATION_QUEUE_NAME, - exchange=notification_exchange, - routing_key=QueueConfig.NOTIFICATION_QUEUE_NAME) - producer.publish( request_data, - declare=[notification_queue], exchange=notification_exchange, content_type='application/json', routing_key=QueueConfig.NOTIFICATION_QUEUE_NAME, diff --git a/backend/AnimatedDrawings/application/task/tasks.py b/backend/AnimatedDrawings/application/task/tasks.py index 3c6cc79f..9d760383 100644 --- a/backend/AnimatedDrawings/application/task/tasks.py +++ b/backend/AnimatedDrawings/application/task/tasks.py @@ -119,13 +119,8 @@ def send_notification(self, _, input_data: dict, filename: str): type='direct', durable=True) - queue = Queue(name=QueueConfig.NOTIFICATION_QUEUE_NAME, - exchange=exchange, - routing_key=QueueConfig.NOTIFICATION_QUEUE_NAME) - producer.publish( request_data, - declare=[queue], exchange=exchange, content_type='application/json', routing_key=QueueConfig.NOTIFICATION_QUEUE_NAME,