code: def k8s_events_handle_experiment_job_statuses(self: 'celery_app.task', payload: Dict) -> None:
      
      details = payload['details']
      job_uuid = details['labels']['job_uuid']
      logger.debug('handling events status for job_uuid: %s, status: %s',
                   job_uuid, payload['status'])
  
      try:
          job = ExperimentJob.objects.get(uuid=job_uuid)
      except ExperimentJob.DoesNotExist:
          logger.debug('Job uuid`%s` does not exist', job_uuid)
          return
  
      try:
          job.experiment
      except Experiment.DoesNotExist:
          logger.debug('Experiment for job `%s` does not exist anymore', job_uuid)
          return
  
      if job.last_status is None and self.request.retries < 2:
          self.retry(countdown=1)
  
      # Set the new status
      try:
          set_node_scheduling(job, details['node_name'])
          job.set_status(status=payload['status'],
                         message=payload['message'],
                         created_at=payload.get('created_at'),
                         traceback=payload.get('traceback'),
                         details=details)
          logger.debug('status %s is set for job %s %s', payload['status'], job_uuid, job.id)
      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)
docs: Experiment jobs statuses