Commit c5adb5ba authored Feb 02, 2021 by Cristiano Urban

Added JSON encoding to response.



Signed-off-by: Cristiano Urban <cristiano.urban@inaf.it>

parent 9ba4c468

transfer_service/get_job_amqp_server.py

+4 −2

Original line number	Diff line number	Diff line
		import json

		from amqp_server import AMQPServer
		from db_connector import DbConnector
		from config import Config
		from db_connector import DbConnector


		class GetJobAMQPServer(AMQPServer):
		@@ -22,7 +24,7 @@ class GetJobAMQPServer(AMQPServer):
		dbResponse = self.dbConn.getJob(requestBody["jobId"])
		self.dbConn.disconnect()
		print(f"Db response: {dbResponse}")
		return dbResponse
		return json.dumps(dbResponse)
		else:
		return 42

transfer_service/start_job_amqp_server.py

+2 −2

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 dbResponse
		return json.dumps(dbResponse)

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