Commit 38bd2576 authored by Cristiano Urban's avatar Cristiano Urban
Browse files

Minor add. 



Signed-off-by: default avatarCristiano Urban <cristiano.urban@inaf.it>
parent bb76aed0

transfer_service/group_rw_rpc_server.py

+27 −4
Original line number Diff line number Diff line
@@ -92,11 +92,34 @@ class GroupRwRPCServer(RedisRPCServer): 
                jobInfo = requestBody.copy()

                jobObj.setInfo(jobInfo)

                jobObj.setPhase("QUEUED")

                #try:

                try:

                    creatorId = self.dbConn.getCreatorId(vospacePath)

                except Exception:

                    errorMsg = "Database error."

                    self.logger.exception(errorMsg)

                    response = { "responseType": "ERROR",

                                 "errorCode": 2,

                                 "errorMsg": errorMsg }

                    return response

                jobObj.setOwnerId(creatorId)

                try:

                    self.dbConn.insertJob(jobObj)

                except Exception:

                    errorMsg = "Database error."

                    self.logger.exception(errorMsg)

                    response = { "responseType": "ERROR",

                                 "errorCode": 2,

                                 "errorMsg": errorMsg }

                    return response

                try:

                    self.groupRwReadyQueue.insertJob(jobObj)

                except Exception:

                    errorMsg = "Cache error."

                    self.logger.exception(errorMsg)

                    response = { "responseType": "ERROR",

                                 "errorCode": 3,

                                 "errorMsg": errorMsg }

                    return response

                response = { "responseType": f"{jobType}_STARTED" }

        elif requestBody["requestType"] == "GRPR_LST":

            vospacePath = requestBody["vospacePath"]