diff options
Diffstat (limited to 'app/workers/bulk_imports/pipeline_worker.rb')
| -rw-r--r-- | app/workers/bulk_imports/pipeline_worker.rb | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/app/workers/bulk_imports/pipeline_worker.rb b/app/workers/bulk_imports/pipeline_worker.rb index 35633b55489..8e5d7013c2c 100644 --- a/app/workers/bulk_imports/pipeline_worker.rb +++ b/app/workers/bulk_imports/pipeline_worker.rb @@ -16,7 +16,7 @@ module BulkImports def perform(pipeline_tracker_id, stage, entity_id) pipeline_tracker = ::BulkImports::Tracker - .with_status(:created, :started) + .with_status(:enqueued) .find_by_id(pipeline_tracker_id) if pipeline_tracker.present? @@ -68,6 +68,8 @@ module BulkImports message: "Retrying error: #{e.message}" ) + pipeline_tracker.update!(status_event: 'retry', jid: jid) + reenqueue(pipeline_tracker, delay: e.retry_delay) else fail_tracker(pipeline_tracker, e) |