Linked REST section to transfer service + minor adds. (7727342a) · Commits · VOSpace INAF / vospace-transfer-service

transfer_service/job.py

+6 −1

Original line number	Diff line number	Diff line
		@@ -6,6 +6,7 @@ class Job(object):
		def __init__(self):
		self.jobId = str(uuid.uuid1().hex)
		self.type = None
		self.runId = None
		self.ownerId = None
		self.phase = None
		self.quote = None
		@@ -15,9 +16,10 @@ class Job(object):
		self.destruction = None
		self.parameters = None
		self.results = None
		self.errorSummary = None
		self.jobInfo = None

		def setID(self, jobId):
		def setId(self, jobId):
		self.jobId = jobId

		def setType(self, type):
		@@ -29,5 +31,8 @@ class Job(object):
		def setPhase(self, phase):
		self.phase = phase

		def setExecutionDuration(self, executionDuration):
		self.executionDuration = executionDuration

		def setInfo(self, jobInfo):
		self.jobInfo = jobInfo

+11 −3

Original line number	Diff line number	Diff line
		import threading # only for testing purposes
		import time # only for testing purposes
		import json

		from amqp_server import AMQPServer
		from db_connector import DbConnector
		@@ -21,10 +22,17 @@ class StartJobAMQPServer(AMQPServer):
		super(StartJobAMQPServer, self).__init__(host, port, queue)

		def execute_callback(self, requestBody):
		out = open("start_job_amqp_server_log.txt", "a")
		out.write(json.dumps(requestBody))
		out.close()
		self.job = Job()
		self.job.setType("pullToVoSpace")
		self.job.setInfo(requestBody)
		self.job.setPhase("PENDING")
		#self.job.setType("pullToVoSpace")
		#self.job.setInfo(requestBody)
		#self.job.setPhase("PENDING")
		self.job.setId(requestBody["jobId"])
		self.job.setType(requestBody["jobInfo"]["transfer"]["direction"])
		self.job.setPhase(requestBody["phase"])
		self.job.setInfo(requestBody["jobInfo"])
		self.dbConn.connect()
		self.job.setOwnerId("0000")
		self.dbConn.insertJob(self.job)