Browse Source

Batches example missing passing request to mark_as_done. Issue #2861

Ask Solem 9 năm trước cách đây
mục cha
commit
93fb98f089
1 tập tin đã thay đổi với 1 bổ sung1 xóa
  1. 1 1
      celery/contrib/batches.py

+ 1 - 1
celery/contrib/batches.py

@@ -57,7 +57,7 @@ messages, and every 10 seconds.
         )
         # use mark_as_done to manually return response data
         for response, request in zip(reponses, requests):
-            app.backend.mark_as_done(request.id, response)
+            app.backend.mark_as_done(request.id, response, request)
 
 
     def wot_api_real(urls):