From 1d0db35e047c6fab91251d9e08fb1ce20c532326 Mon Sep 17 00:00:00 2001 From: Sergei Trofimov Date: Mon, 20 Mar 2017 16:27:58 +0000 Subject: [PATCH] Fix timstampts to be UTC. --- wa/framework/execution.py | 4 ++-- wa/framework/run.py | 6 +++--- 2 files changed, 5 insertions(+), 5 deletions(-) diff --git a/wa/framework/execution.py b/wa/framework/execution.py index 51d22725..7a32cda1 100644 --- a/wa/framework/execution.py +++ b/wa/framework/execution.py @@ -107,7 +107,7 @@ class ExecutionContext(object): self.failed_jobs = 0 def start_run(self): - self.output.info.start_time = datetime.now() + self.output.info.start_time = datetime.utcnow() self.output.write_info() self.job_queue = copy(self.cm.jobs) self.completed_jobs = [] @@ -125,7 +125,7 @@ class ExecutionContext(object): status = Status.FAILED self.run_state.status = status self.output.status = status - self.output.info.end_time = datetime.now() + self.output.info.end_time = datetime.utcnow() self.output.info.duration = self.output.info.end_time -\ self.output.info.start_time self.output.write_info() diff --git a/wa/framework/run.py b/wa/framework/run.py index 8510fc12..815ae4c9 100644 --- a/wa/framework/run.py +++ b/wa/framework/run.py @@ -81,7 +81,7 @@ class RunState(object): def __init__(self): self.jobs = OrderedDict() self.status = Status.NEW - self.timestamp = datetime.now() + self.timestamp = datetime.utcnow() def add_job(self, job): job_state = JobState(job.id, job.label, job.iteration, job.status) @@ -90,7 +90,7 @@ class RunState(object): def update_job(self, job): state = self.jobs[(job.id, job.iteration)] state.status = job.status - state.timestamp = datetime.now() + state.timestamp = datetime.utcnow() def get_status_counts(self): counter = Counter() @@ -126,7 +126,7 @@ class JobState(object): self.iteration = iteration self.status = status self.retries = 0 - self.timestamp = datetime.now() + self.timestamp = datetime.utcnow() def to_pod(self): return OrderedDict(