diff --git a/arkindex_worker/worker/transcription.py b/arkindex_worker/worker/transcription.py index 6f53a126b5b8eb4c4cfc2428056355cb088dea94..80300cfce0ab06ef8cf11b4cc0da67bf7f11fc0a 100644 --- a/arkindex_worker/worker/transcription.py +++ b/arkindex_worker/worker/transcription.py @@ -450,17 +450,27 @@ class TranscriptionMixin: if worker_version is not None: # If worker_version=False, filter by manual worker_version e.g. None - worker_version_id = worker_version if worker_version else None - transcriptions = transcriptions.where( - CachedTranscription.worker_version_id == worker_version_id - ) + worker_version_id = worker_version or None + if worker_version_id: + transcriptions = transcriptions.where( + CachedTranscription.worker_version_id == worker_version_id + ) + else: + transcriptions = transcriptions.where( + CachedTranscription.worker_version_id.is_null() + ) if worker_run is not None: # If worker_run=False, filter by manual worker_run e.g. None - worker_run_id = worker_run if worker_run else None - transcriptions = transcriptions.where( - CachedTranscription.worker_run_id == worker_run_id - ) + worker_run_id = worker_run or None + if worker_run_id: + transcriptions = transcriptions.where( + CachedTranscription.worker_run_id == worker_run_id + ) + else: + transcriptions = transcriptions.where( + CachedTranscription.worker_run_id.is_null() + ) else: transcriptions = self.api_client.paginate( "ListTranscriptions", id=element.id, **query_params