diff options
Diffstat (limited to 'app/workers/bulk_imports/entity_worker.rb')
| -rw-r--r-- | app/workers/bulk_imports/entity_worker.rb | 5 |
1 files changed, 4 insertions, 1 deletions
diff --git a/app/workers/bulk_imports/entity_worker.rb b/app/workers/bulk_imports/entity_worker.rb index 5c04cdc96a0..70d6626df91 100644 --- a/app/workers/bulk_imports/entity_worker.rb +++ b/app/workers/bulk_imports/entity_worker.rb @@ -12,6 +12,9 @@ module BulkImports worker_has_external_dependencies! + idempotent! + deduplicate :until_executed, including_scheduled: true + def perform(entity_id, current_stage = nil) return if stage_running?(entity_id, current_stage) @@ -48,7 +51,7 @@ module BulkImports end def next_pipeline_trackers_for(entity_id) - BulkImports::Tracker.next_pipeline_trackers_for(entity_id) + BulkImports::Tracker.next_pipeline_trackers_for(entity_id).update(status_event: 'enqueue') end def logger |