Skip to content

Commit

Permalink
Remove Celery task_acks_late (#1469)
Browse files Browse the repository at this point in the history
This is to disable implicit retries by Celery because it causes duplicate tasks that the task manager does not deal with appropriately when a task has timed out because the task stub has already been removed, which means that new Jobs do not get created based on the output evidence from the retried task.
  • Loading branch information
aarontp committed Apr 12, 2024
1 parent fa77f37 commit 64332e4
Showing 1 changed file with 0 additions and 1 deletion.
1 change: 0 additions & 1 deletion turbinia/tcelery.py
Original file line number Diff line number Diff line change
Expand Up @@ -56,7 +56,6 @@ def setup(self):
broker_connection_retry_on_startup=True,
task_default_queue=config.INSTANCE_ID,
accept_content=['json'],
task_acks_late=True,
worker_cancel_long_running_tasks_on_connection_loss=True,
worker_concurrency=1,
worker_prefetch_multiplier=1,
Expand Down

0 comments on commit 64332e4

Please sign in to comment.