add queue to vtex tasks

weni-ai · Jan 15, 2024 · eb33281 · eb33281
1 parent 9ef7f16
commit eb33281
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 0 deletions.
diff --git 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
@@ -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)