Merge branch 'feature/add-queue-in-send-task' of https://github.com/w…

…eni-ai/weni-integrations-engine into staging
weni-ai · Jan 15, 2024 · 72eea24 · 72eea24
2 parents 32dcb9b + eb33281
commit 72eea24
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
@@ -122,6 +122,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)