How to wait for task completes with celery chain? – Shopify
I am trying to create a celery chain here: chain(getAllProducts.s(shopname, hdrs), editOgTags.s(title, description, whichImage, readableShopname, currentThemeId), notifyBulkEditFinish.si(email, name, readableShopname, totalProducts), updateBulkEditTask.si(taskID))() In editOgTags, there are 3 subtasks: @shared_task(ignore_result=True) def editOgTags(products, title, description, whichImage, readableShopname, currentThemeId): for product in products: editOgTitle.delay(product,…