From eb33281cca336f044c35084838a5ea98b116b60c Mon Sep 17 00:00:00 2001 From: lucaslinhares Date: Mon, 15 Jan 2024 18:45:29 -0300 Subject: [PATCH] add queue to vtex tasks --- .../core/types/channels/whatsapp_cloud/catalogs/views/views.py | 1 + marketplace/webhooks/vtex/product_updates.py | 1 + 2 files changed, 2 insertions(+) diff --git a/marketplace/core/types/channels/whatsapp_cloud/catalogs/views/views.py b/marketplace/core/types/channels/whatsapp_cloud/catalogs/views/views.py index 74ccc0ae..67fe2057 100644 --- a/marketplace/core/types/channels/whatsapp_cloud/catalogs/views/views.py +++ b/marketplace/core/types/channels/whatsapp_cloud/catalogs/views/views.py @@ -116,6 +116,7 @@ def create(self, request, app_uuid, *args, **kwargs): celery_app.send_task( name="task_insert_vtex_products", kwargs={"credentials": credentials, "catalog_uuid": str(catalog.uuid)}, + queue="product_synchronization", ) return Response(CatalogSerializer(catalog).data, status=status.HTTP_201_CREATED) diff --git a/marketplace/webhooks/vtex/product_updates.py b/marketplace/webhooks/vtex/product_updates.py index def4b019..995fdf19 100644 --- a/marketplace/webhooks/vtex/product_updates.py +++ b/marketplace/webhooks/vtex/product_updates.py @@ -28,6 +28,7 @@ def post(self, request, app_uuid): celery_app.send_task( name="task_update_vtex_products", kwargs={"webhook_data": request.data, "app_uuid": app_uuid}, + queue="product_synchronization", ) return Response(status=status.HTTP_200_OK)