diff --git a/transfer_service/db_connector.py b/transfer_service/db_connector.py index 3fc13669dc59022aafa5a6d03cdc8f73f12f86f2..fabca6ec04bb7fb9e706f34c478d3fbcc94b1152 100644 --- a/transfer_service/db_connector.py +++ b/transfer_service/db_connector.py @@ -414,10 +414,16 @@ class DbConnector(object): start_time, owner_id FROM job - WHERE phase - NOT IN ('ABORTED', - 'COMPLETED', - 'ERROR') + WHERE phase NOT IN ('ABORTED', + 'COMPLETED', + 'ERROR') + AND + job_type IN ('pullFromVoSpace', + 'pullToVoSpace', + 'pushToVoSpace', + 'vos_data', + 'vos_group', + 'vos_import') ORDER BY creation_time DESC; """) result = cursor.fetchall() @@ -451,6 +457,13 @@ class DbConnector(object): owner_id FROM job WHERE phase = %s + AND + job_type IN ('pullFromVoSpace', + 'pullToVoSpace', + 'pushToVoSpace', + 'vos_data', + 'vos_group', + 'vos_import') ORDER BY creation_time DESC; """, (phase,)) @@ -464,6 +477,13 @@ class DbConnector(object): owner_id FROM job WHERE phase = %s + AND + job_type IN ('pullFromVoSpace', + 'pullToVoSpace', + 'pushToVoSpace', + 'vos_data', + 'vos_group', + 'vos_import') ORDER BY creation_time DESC; """, (phase,))