Commit 2f7198e7 authored by Cristiano Urban's avatar Cristiano Urban
Browse files

Added owner id obtained from REST api + removed fake job update + minor changes. 



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

transfer_service/start_job_amqp_server.py

+14 −14
Original line number Diff line number Diff line 
import threading # only for testing purposes

import time      # only for testing purposes

#import threading # only for testing purposes

#import time      # only for testing purposes

import json



from amqp_server import AMQPServer
@@ -35,15 +35,15 @@ class StartJobAMQPServer(AMQPServer): 
        self.job.setType(requestBody["jobInfo"]["transfer"]["direction"])

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

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

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

        self.dbConn.connect()

        self.job.setOwnerId("0000")

        self.dbConn.insertJob(self.job)

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

        self.dbConn.disconnect()

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

        self.pendingQueueRead.insertJob(self.job)

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

        t.start()                                    # only for testing purposes

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

        #t.start()                                    # only for testing purposes

        return dbResponse

      

    def run(self):
@@ -51,11 +51,11 @@ class StartJobAMQPServer(AMQPServer): 
        super(StartJobAMQPServer, self).run()



    # only for testing purposes        

    def fake_job(self):

        time.sleep(10)

        print("fake_job: changing job state...")

        self.job.setPhase("EXECUTING")

        self.dbConn.connect()

        self.dbConn.insertJob(self.job)

        self.dbConn.disconnect()

        print("fake_job: state changed!")
 
 No newline at end of file
 
    #def fake_job(self):

    #    time.sleep(10)

    #    print("fake_job: changing job state...")

    #    self.job.setPhase("EXECUTING")

    #    self.dbConn.connect()

    #    self.dbConn.insertJob(self.job)

    #    self.dbConn.disconnect()

    #    print("fake_job: state changed!")
 
 No newline at end of file