Commit d930a8dd authored Sep 06, 2021 by Cristiano Urban

Added filter to 'vos_job list' command.



Signed-off-by: Cristiano Urban <cristiano.urban@inaf.it>

parent 535a4ed8

transfer_service/db_connector.py

+24 −4

Original line number	Diff line number	Diff line
		@@ -414,10 +414,16 @@ class DbConnector(object):
		start_time,
		owner_id
		FROM job
		WHERE phase
		NOT IN ('ABORTED',
		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,))