Commit 548e8404 authored by Cristiano Urban's avatar Cristiano Urban
Browse files

Minor changes. 



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

transfer_service/data_rpc_server.py

+10 −10
Original line number Diff line number Diff line
@@ -164,13 +164,13 @@ class DataRPCServer(RedisRPCServer): 
        elif requestBody["requestType"] == "STORE_CON":

            username = requestBody["userName"]

            self.prepare(username)

            job = Job()

            job.setType("vos_data")

            job.setInfo(requestBody)

            job.setPhase("PENDING")

            jobObj = Job()

            jobObj.setType("vos_data")

            jobObj.setInfo(requestBody)

            jobObj.setPhase("PENDING")

            try:

                job.setOwnerId(self.dbConn.getUserId(username))

                self.dbConn.insertJob(job)

                jobObj.setOwnerId(self.dbConn.getUserId(username))

                self.dbConn.insertJob(jobObj)

            except Exception:

                errorMsg = "Database error."

                self.logger.exception(errorMsg)
@@ -178,10 +178,10 @@ class DataRPCServer(RedisRPCServer): 
                             "errorCode": 3,

                             "errorMsg": errorMsg }

                return response

            job.jobInfo["storageId"] = requestBody["storageId"]

            job.jobInfo["storageType"] = requestBody["storageType"]

            jobObj.jobInfo["storageId"] = requestBody["storageId"]

            jobObj.jobInfo["storageType"] = requestBody["storageType"]

            try:

                self.pendingQueueWrite.insertJob(job)

                self.pendingQueueWrite.insertJob(jobObj)

            except Exception:

                errorMsg = "Unable to insert the job in the 'write_pending' queue."

                self.logger.exception(errorMsg)
@@ -191,7 +191,7 @@ class DataRPCServer(RedisRPCServer): 
                return response

            else:

                response = { "responseType": "STORE_RUN", 

                             "jobId": job.jobId }

                             "jobId": jobObj.jobId }

        else:

            errorMsg = "Unkown request type."

            self.logger.error(errorMsg)