Skip to content
Snippets Groups Projects
Commit 796598d0 authored by Alex Wiens's avatar Alex Wiens
Browse files

Prule.daemon: Fix variable

parent 980aa037
No related branches found
No related tags found
No related merge requests found
...@@ -802,7 +802,7 @@ class PruleThread(threading.Thread): ...@@ -802,7 +802,7 @@ class PruleThread(threading.Thread):
job_meta = job_res['Meta'] job_meta = job_res['Meta']
job_cluster = job_meta["cluster"] job_cluster = job_meta["cluster"]
job_slurmid = str(job_meta["jobId"]) job_slurmid = job_meta["jobId"]
job_startTime = str(job_meta["startTime"]) if type(job_meta["startTime"]) == int else str(int(datetime.datetime.fromisoformat(job_meta['startTime']).timestamp())) job_startTime = str(job_meta["startTime"]) if type(job_meta["startTime"]) == int else str(int(datetime.datetime.fromisoformat(job_meta['startTime']).timestamp()))
# prepare job path for filesystem access or download jobarchive from API # prepare job path for filesystem access or download jobarchive from API
...@@ -811,7 +811,7 @@ class PruleThread(threading.Thread): ...@@ -811,7 +811,7 @@ class PruleThread(threading.Thread):
if config.config["API_JOBARCHIVE"] == False: if config.config["API_JOBARCHIVE"] == False:
# Load job from filesystem # Load job from filesystem
job_path = os.path.join(config.config["JOBARCHIVE_PATH"], job_cluster, job_slurmid[:-3], job_slurmid[-3:], job_startTime) job_path = os.path.join(config.config["JOBARCHIVE_PATH"], job_cluster, str(job_slurmid)[:-3], str(job_slurmid)[-3:], job_startTime)
else: else:
# Load job from jobarchive api and write it to tempdir # Load job from jobarchive api and write it to tempdir
with prule.debug.Timing("prulethread.request_jobarchive", "PRINT_TIMING" in config.config): with prule.debug.Timing("prulethread.request_jobarchive", "PRINT_TIMING" in config.config):
......
0% Loading or .
You are about to add 0 people to the discussion. Proceed with caution.
Please register or to comment