diff --git a/apps/worker/tasks/upload_finisher.py b/apps/worker/tasks/upload_finisher.py index 7c9daed09..b986f3148 100644 --- a/apps/worker/tasks/upload_finisher.py +++ b/apps/worker/tasks/upload_finisher.py @@ -294,7 +294,8 @@ def run_impl( # Only skip if ALL uploads exist in DB and ALL are in final states if len(uploads_in_db) == len(upload_ids): all_already_processed = all( - upload.state in ("processed", "error") for upload in uploads_in_db + upload.state in ("merged", "processed", "error") + for upload in uploads_in_db ) if all_already_processed: log.info(