Commit 68dc195b authored by Cristiano Urban's avatar Cristiano Urban
Browse files

Fixed wrong behavior on 'StartJobAMQPServer' class. 



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

transfer_service/start_job_amqp_server.py

+8 −7
Original line number Diff line number Diff line
@@ -33,13 +33,13 @@ class StartJobAMQPServer(RedisRpcServer): 
        # debug block...

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

        out.write(json.dumps(requestBody))

        out.close()

        

        

        job = Job()

        job.setId(requestBody["jobId"])

        job.setType(requestBody["jobInfo"]["transfer"]["direction"])        

        job.setInfo(requestBody["jobInfo"])

        job.setOwnerId(requestBody["ownerId"])

        job.setId(requestBody["job"]["jobId"])

        job.setType(requestBody["job"]["jobInfo"]["transfer"]["direction"])        

        job.setInfo(requestBody["job"]["jobInfo"])

        job.setOwnerId(requestBody["job"]["ownerId"])

        if self.pendingQueueRead.len() >= self.maxPendingJobs:

            job.setPhase("ERROR")

            job.setErrorType("transient")
@@ -49,13 +49,14 @@ class StartJobAMQPServer(RedisRpcServer): 
                    self.terminatedQueueRead.extractJob()

            self.terminatedQueueRead.insertJob(job)            

        else:

            job.setPhase(requestBody["phase"])

            job.setPhase(requestBody["job"]["phase"])

            self.dbConn.insertJob(job)

            self.pendingQueueRead.insertJob(job)

        response = self.dbConn.getJob(job.jobId)

        

        # debug block...

        print(f"Db response: {response}")

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

        out.close()

        

        return response