d4e5d249e8f1650aeb5ac8775552526c4d2cc033,polyaxon/scheduler/tasks/jobs.py,,jobs_schedule_deletion,#Any#Any#,74

Before Change

    job.archive()

    if not job.is_running:
        return

    project = job.project
    celery_app.send_task(
        SchedulerCeleryTasks.JOBS_STOP,
        kwargs={
            "project_name": project.unique_name,
            "project_uuid": project.uuid.hex,
            "job_name": job.unique_name,
            "job_uuid": job.uuid.hex,
            "update_status": True,
            "collect_logs": False,
            "message": "Job is scheduled for deletion."
        })

    if immediate:
        celery_app.send_task(
            SchedulerCeleryTasks.DELETE_ARCHIVED_JOB,

After Change

    job.archive()

    if job.is_running:
        project = job.project
        celery_app.send_task(
            SchedulerCeleryTasks.JOBS_STOP,
            kwargs={
                "project_name": project.unique_name,
                "project_uuid": project.uuid.hex,
                "job_name": job.unique_name,
                "job_uuid": job.uuid.hex,
                "update_status": True,
                "collect_logs": False,
                "message": "Job is scheduled for deletion."
            })

    if immediate:
        celery_app.send_task(
            SchedulerCeleryTasks.DELETE_ARCHIVED_JOB,
            kwargs={

Instances