added queue name

jlab-sensing · Jul 10, 2024 · e81d711 · e81d711
1 parent d6aaed7
commit e81d711
Showing 1 changed file with 1 addition and 9 deletions.
diff --git a/backend/api/__init__.py b/backend/api/__init__.py
@@ -76,7 +76,7 @@ def create_app(debug: bool = False) -> Flask:
                     "region": os.getenv("AWS_DEFAULT_REGION"),
                     "visibility_timeout": timedelta(minutes=15).total_seconds(),
                     "predefined_queues": {
-                        "celery": {  ## the name of the SQS queue
+                        "dirtviz-task-queue": {  ## the name of the SQS queue
                             "url": os.getenv("AWS_SQS_URL"),
                             "access_key_id": os.getenv("AWS_ACCESS_KEY_ID"),
                             "secret_access_key": os.getenv("AWS_SECRET_ACCESS_KEY"),
@@ -97,15 +97,7 @@ def create_app(debug: bool = False) -> Flask:
                     result_backend=os.getenv("CELERY_RESULT_BACKEND"),
                     task_ignore_result=True,
                     broker_transport_options={
-                        "region": os.getenv("AWS_DEFAULT_REGION"),
                         "visibility_timeout": timedelta(minutes=15).total_seconds(),
-                        "predefined_queues": {
-                            "celery": {  ## the name of the SQS queue
-                                "url": os.getenv("AWS_SQS_URL"),
-                                "access_key_id": os.getenv("AWS_ACCESS_KEY_ID"),
-                                "secret_access_key": os.getenv("AWS_SECRET_ACCESS_KEY"),
-                            }
-                        },
                     },
                     task_create_missing_queues=False,
                     task_ack_late=True,