Use Celery immutable signature so it does not take the result of the header task

This commit is contained in:
Trenton Holmes
2024-04-06 08:01:39 -07:00
committed by Trenton H
parent 957691c454
commit 05571ff751

View File

@@ -195,7 +195,7 @@ def rotate(doc_ids: list[int], degrees: int):
logger.exception(f"Error rotating document {doc.id}: {e}")
if len(affected_docs) > 0:
bulk_update_task = bulk_update_documents.s(document_ids=affected_docs)
bulk_update_task = bulk_update_documents.si(document_ids=affected_docs)
chord(header=rotate_tasks, body=bulk_update_task).delay()
return "OK"