Commit 9bf3e315 authored by Cristiano Urban's avatar Cristiano Urban
Browse files

Fixed issue in 'RetrieveCleaner' class + minor changes. 



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

transfer_service/retrieve_cleaner.py

+1 −1
Original line number Diff line number Diff line
@@ -139,7 +139,7 @@ class RetrieveCleaner(TaskExecutor): 
            except Exception:

                self.logger.exception("Cache error: failed to retrieve queue length.")

            else:

                if destQueueLen < self.maxReadyJobs and srcQueueLen > 0:

                if destQueueLen < self.maxCleanJobs and srcQueueLen > 0:

                    self.jobObj = self.srcQueue.getJob()

                    self.nodeList = self.jobObj.nodeList.copy()

                    self.destPathList = self.jobObj.jobInfo["destPathList"].copy()

transfer_service/start_job_rpc_server.py

+4 −4
Original line number Diff line number Diff line
@@ -52,8 +52,8 @@ class StartJobRPCServer(RedisRPCServer): 


    def callback(self, requestBody):

        # debug block...

        out = open("start_job_amqp_server_log.txt", "a")

        out.write(json.dumps(requestBody))

        #out = open("start_job_amqp_server_log.txt", "a")

        #out.write(json.dumps(requestBody))



        job = Job()

        job.setId(requestBody["job"]["jobId"])
@@ -125,8 +125,8 @@ class StartJobRPCServer(RedisRPCServer): 
                         "errorMsg": errorMsg }



        # debug block...

        out.write(f"Db response: {response}")

        out.close()

        #out.write(f"Db response: {response}")

        #out.close()



        return response