@celery_app.task(name=K8SEventsCeleryTasks.K8S_EVENTS_HANDLE_JOB_STATUSES,<EOL>bind=True,<EOL>max_retries=<NUM_LIT:3>,<EOL>ignore_result=True)<EOL>def k8s_events_handle_job_statuses(self: '<STR_LIT>', payload: Dict) -> None:
details = payload['<STR_LIT>']<EOL>job_uuid = details['<STR_LIT>']['<STR_LIT>']<EOL>job_name = details['<STR_LIT>']['<STR_LIT>']<EOL>project_name = details['<STR_LIT>'].get('<STR_LIT>')<EOL>logger.debug('<STR_LIT>', job_name)<EOL>try:<EOL><INDENT>job = Job.objects.get(uuid=job_uuid)<EOL><DEDENT>except Job.DoesNotExist:<EOL><INDENT>logger.debug('<STR_LIT>', job_name)<EOL>return<EOL><DEDENT>try:<EOL><INDENT>job.project<EOL><DEDENT>except Project.DoesNotExist:<EOL><INDENT>logger.debug('<STR_LIT>', project_name)<EOL>return<EOL><DEDENT>try:<EOL><INDENT>set_node_scheduling(job, details['<STR_LIT>'])<EOL>job.set_status(status=payload['<STR_LIT:status>'],<EOL>message=payload['<STR_LIT:message>'],<EOL>traceback=payload.get('<STR_LIT>'),<EOL>details=details)<EOL><DEDENT>except IntegrityError:<EOL><INDENT>self.retry(countdown=Intervals.EXPERIMENTS_SCHEDULER)<EOL><DEDENT>
Project jobs statuses