diff --git a/hyrex/dispatcher/sqlc/set_orphaned_task_execution_to_lost_and_retry.py b/hyrex/dispatcher/sqlc/set_orphaned_task_execution_to_lost_and_retry.py index 6c05533..c51af0b 100644 --- a/hyrex/dispatcher/sqlc/set_orphaned_task_execution_to_lost_and_retry.py +++ b/hyrex/dispatcher/sqlc/set_orphaned_task_execution_to_lost_and_retry.py @@ -64,6 +64,7 @@ NOW() FROM lost_tasks WHERE attempt_number < max_retries +ON CONFLICT (task_name, idempotency_key) WHERE idempotency_key IS NOT NULL DO NOTHING """