diff --git a/queue_job/controllers/main.py b/queue_job/controllers/main.py index f83aa9b54f..dff6f4fe1c 100644 --- a/queue_job/controllers/main.py +++ b/queue_job/controllers/main.py @@ -34,6 +34,9 @@ def _try_perform_job(self, env, job): _logger.debug("%s started", job) job.perform() + # Triggers any stored computed fields before calling 'set_done' + # so that will be part of the 'exec_time' + env["base"].flush() job.set_done() job.store() env["base"].flush()