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, 4 insertions, 0 deletions
diff --git a/app/workers/bulk_imports/pipeline_worker.rb b/app/workers/bulk_imports/pipeline_worker.rb index 8e5d7013c2c..03ec2f058ca 100644 --- a/app/workers/bulk_imports/pipeline_worker.rb +++ b/app/workers/bulk_imports/pipeline_worker.rb @@ -43,6 +43,10 @@ module BulkImports private def run(pipeline_tracker) + if pipeline_tracker.entity.failed? + raise(Entity::FailedError, 'Failed entity status') + end + if ndjson_pipeline?(pipeline_tracker) status = ExportStatus.new(pipeline_tracker, pipeline_tracker.pipeline_class.relation) |