From 019bf189c9622b299691dbe3b71cefa0bf2ee8dc Mon Sep 17 00:00:00 2001 From: Vojta Udrzal Date: Tue, 20 Apr 2021 08:39:09 +0200 Subject: [PATCH] Populate Task.ts field in Task.from_id fn (#195) --- tasktiger/task.py | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/tasktiger/task.py b/tasktiger/task.py index 4601ff76..005f4863 100644 --- a/tasktiger/task.py +++ b/tasktiger/task.py @@ -441,15 +441,14 @@ def from_id(self, tiger, queue, state, task_id, load_executions=0): ) ( serialized_data, - is_queued, + score, serialized_executions, ) = pipeline.execute() else: - serialized_data, is_queued = pipeline.execute() + serialized_data, score = pipeline.execute() serialized_executions = [] - # XXX: No timestamp for now - if serialized_data and is_queued: + if serialized_data and score: data = json.loads(serialized_data) executions = [json.loads(e) for e in serialized_executions if e] return Task( @@ -458,6 +457,7 @@ def from_id(self, tiger, queue, state, task_id, load_executions=0): _data=data, _state=state, _executions=executions, + _ts=datetime.datetime.utcfromtimestamp(score), ) else: raise TaskNotFound('Task {} not found.'.format(task_id))