Loading transfer_service/db_connector.py +12 −5 Original line number Diff line number Diff line Loading @@ -95,16 +95,23 @@ class DbConnector(object): self.cursor.execute("SELECT * FROM job WHERE job_id = %s;", (jobId,)) out = open("db_connector_log.txt", "a") result = self.cursor.fetchall() out.write(f"result: {result}\n\n") out.close() #out.write(f"result: {result}\n\n") #out.close() if not result: return json.loads('{ "error": "JOB_NOT_FOUND" }') else: job = dict() for idx in result[0]: el = result[0][idx] oldIdx = idx idxTokens = idx.split('_') idx = idxTokens[0] + ''.join(token.title() for token in idxTokens[1:]) job[idx] = result[0][oldIdx] el = job[idx] if isinstance(el, datetime.datetime): result[0][idx] = str(el) return result[0] job[idx] = str(el) out.write(f"job: {job}\n\n") out.close() return job def getRapId(self, username): """Returns the RAP id for a given user name.""" Loading Loading
transfer_service/db_connector.py +12 −5 Original line number Diff line number Diff line Loading @@ -95,16 +95,23 @@ class DbConnector(object): self.cursor.execute("SELECT * FROM job WHERE job_id = %s;", (jobId,)) out = open("db_connector_log.txt", "a") result = self.cursor.fetchall() out.write(f"result: {result}\n\n") out.close() #out.write(f"result: {result}\n\n") #out.close() if not result: return json.loads('{ "error": "JOB_NOT_FOUND" }') else: job = dict() for idx in result[0]: el = result[0][idx] oldIdx = idx idxTokens = idx.split('_') idx = idxTokens[0] + ''.join(token.title() for token in idxTokens[1:]) job[idx] = result[0][oldIdx] el = job[idx] if isinstance(el, datetime.datetime): result[0][idx] = str(el) return result[0] job[idx] = str(el) out.write(f"job: {job}\n\n") out.close() return job def getRapId(self, username): """Returns the RAP id for a given user name.""" Loading