diff --git a/docker-app/worker_wrapper/wrapper.py b/docker-app/worker_wrapper/wrapper.py index 3c727de48..4f0108226 100644 --- a/docker-app/worker_wrapper/wrapper.py +++ b/docker-app/worker_wrapper/wrapper.py @@ -157,21 +157,14 @@ def run(self): feedback["error_stack"] = "" try: - logger.info( - "Set job status to `failed` due to being killed by the docker engine.", - ) - - self.job.output = output.decode("utf-8") - self.job.feedback = feedback - self.job.status = Job.Status.FAILED - self.job.save(update_fields=["output", "feedback", "status"]) + self.job.refresh_from_db() except Exception as err: logger.error( "Failed to update job status, probably does not exist in the database.", exc_info=err, ) - # No further action required, probably received by wrapper's autoclean mechanism when the `Project` is deleted - return + # No further action required, probably received by wrapper's autoclean mechanism when the `Project` is deleted + return elif exit_code == TIMEOUT_ERROR_EXIT_CODE: feedback["error"] = "Worker timeout error." feedback["error_type"] = "TIMEOUT"