diff --git a/transfer_service/db_connector.py b/transfer_service/db_connector.py index 010d748ac65451c2a298a7f195c4b97895792bd9..3ab6866063a5356eb0116ef24925eb7d02a54a63 100644 --- a/transfer_service/db_connector.py +++ b/transfer_service/db_connector.py @@ -427,8 +427,7 @@ class DbConnector(object): 'pullToVoSpace', 'pushToVoSpace', 'vos_data', - 'vos_grpr', - 'vos_grpw', + 'vos_group', 'vos_import') ORDER BY creation_time DESC; """) @@ -468,8 +467,7 @@ class DbConnector(object): 'pullToVoSpace', 'pushToVoSpace', 'vos_data', - 'vos_grpr', - 'vos_grpw', + 'vos_group', 'vos_import') ORDER BY creation_time DESC; """, @@ -489,8 +487,7 @@ class DbConnector(object): 'pullToVoSpace', 'pushToVoSpace', 'vos_data', - 'vos_grpr', - 'vos_grpw', + 'vos_group', 'vos_import') ORDER BY creation_time DESC; """, diff --git a/transfer_service/group_rw_rpc_server.py b/transfer_service/group_rw_rpc_server.py index 1d2cd94ac3b137b92c514490f6cb3902dccab932..500e60163b40dfd21d919a7cba096809f75e5b5f 100644 --- a/transfer_service/group_rw_rpc_server.py +++ b/transfer_service/group_rw_rpc_server.py @@ -90,7 +90,7 @@ class GroupRwRPCServer(RedisRPCServer): "errorMsg": errorMsg } else: jobObj = Job() - jobObj.setType(f"vos_{jobType.lower()}") + jobObj.setType("vos_group") jobInfo = requestBody.copy() jobObj.setInfo(jobInfo) jobObj.setPhase("QUEUED")