From f1abed13d67708029414cee19d8b419459cf565c Mon Sep 17 00:00:00 2001 From: jasquat Date: Wed, 6 Mar 2024 15:48:24 -0500 Subject: [PATCH] remove unused arg from celery worker producer w/ burnettk --- .../celery_tasks/process_instance_task_producer.py | 2 -- 1 file changed, 2 deletions(-) diff --git a/spiffworkflow-backend/src/spiffworkflow_backend/background_processing/celery_tasks/process_instance_task_producer.py b/spiffworkflow-backend/src/spiffworkflow_backend/background_processing/celery_tasks/process_instance_task_producer.py index 095827e2d..f97296048 100644 --- a/spiffworkflow-backend/src/spiffworkflow_backend/background_processing/celery_tasks/process_instance_task_producer.py +++ b/spiffworkflow-backend/src/spiffworkflow_backend/background_processing/celery_tasks/process_instance_task_producer.py @@ -21,8 +21,6 @@ def queue_future_task_if_appropriate(process_instance: ProcessInstanceModel, eta args_to_celery = { "process_instance_id": process_instance.id, "task_guid": task_guid, - # the producer_identifier is so we can know what is putting messages in the queue - "producer_identifier": "future_task", } # add buffer to countdown to avoid rounding issues and race conditions with spiff. the situation we want to avoid is where # we think the timer said to run it at 6:34:11, and we initialize the SpiffWorkflow library,