Add debugging logs
@@ -70,8 +70,10 @@ def events_handle_experiment_job_statuses(self, payload):
message=payload['message'],
traceback=payload.get('traceback'),
details=details)
+ _logger.info('status %s is set for job %s', payload['status'], job_uuid)
except IntegrityError:
# Due to concurrency this could happen, we just retry it
+ _logger.info('Retry job status %s handling %s', payload['status'], job_uuid)
self.retry(countdown=Intervals.EXPERIMENTS_SCHEDULER)
