Commit 81d1b0a5 authored by Cristiano Urban's avatar Cristiano Urban
Browse files

Minor changes. 



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

transfer_service/import_rpc_server.py

+3 −3
Original line number Diff line number Diff line
@@ -40,7 +40,7 @@ class ImportRPCServer(RedisRPCServer): 
            username = requestBody["userName"]

            userInDb = self.dbConn.userExists(username)

            userInfo = self.systemUtils.userInfo(username)

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

            #out = open("import_amqp_server_log.txt", "a")



            if not userInfo or not userInDb:

                response = { "responseType": "ERROR",
@@ -92,8 +92,8 @@ class ImportRPCServer(RedisRPCServer): 
                jobObj.setOwnerId(userId)

                self.dbConn.insertJob(jobObj)

                self.importReadyQueue.insertJob(jobObj)

                out.write(requestBody.copy())

                out.close()

                #out.write(requestBody.copy())

                #out.close()



                response = { "responseType": "IMPORT_STARTED" }

        else:

transfer_service/import_executor.py

+34 −34

File changed.

Contains only whitespace changes.