Commit 69324dfc authored by Cristiano Urban's avatar Cristiano Urban
Browse files

Removed json.dumps() method. 



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

transfer_service/get_job_amqp_server.py

+1 −1
Original line number Diff line number Diff line
@@ -24,7 +24,7 @@ class GetJobAMQPServer(AMQPServer): 
            dbResponse = self.dbConn.getJob(requestBody["jobId"])

            self.dbConn.disconnect()

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

            return json.dumps(dbResponse)

            return dbResponse

        else:

            return 42

transfer_service/start_job_amqp_server.py

+1 −1
Original line number Diff line number Diff line
@@ -44,7 +44,7 @@ class StartJobAMQPServer(AMQPServer): 
        self.pendingQueueRead.insertJob(self.job)

        #t = threading.Thread(target = self.fake_job) # only for testing purposes

        #t.start()                                    # only for testing purposes

        return json.dumps(dbResponse)

        return dbResponse

      

    def run(self):

        print(f"Starting AMQP server of type {self.type}...")