|
@@ -430,55 +430,6 @@ def test_cancel_subsequent_jobs():
|
|
|
assert_true_after_time(lambda: _OrchestratorFactory._orchestrator.jobs_to_run.qsize() == 0)
|
|
|
|
|
|
|
|
|
-def test_is_deletable():
|
|
|
- assert len(_JobManager._get_all()) == 0
|
|
|
- task = _create_task(print, 0, "task")
|
|
|
- job = _OrchestratorFactory._orchestrator.submit_task(task).jobs[0]
|
|
|
-
|
|
|
- assert job.is_completed()
|
|
|
- assert _JobManager._is_deletable(job)
|
|
|
- assert _JobManager._is_deletable(job.id)
|
|
|
-
|
|
|
- job.abandoned()
|
|
|
- assert job.is_abandoned()
|
|
|
- assert _JobManager._is_deletable(job)
|
|
|
- assert _JobManager._is_deletable(job.id)
|
|
|
-
|
|
|
- job.canceled()
|
|
|
- assert job.is_canceled()
|
|
|
- assert _JobManager._is_deletable(job)
|
|
|
- assert _JobManager._is_deletable(job.id)
|
|
|
-
|
|
|
- job.failed()
|
|
|
- assert job.is_failed()
|
|
|
- assert _JobManager._is_deletable(job)
|
|
|
- assert _JobManager._is_deletable(job.id)
|
|
|
-
|
|
|
- job.skipped()
|
|
|
- assert job.is_skipped()
|
|
|
- assert _JobManager._is_deletable(job)
|
|
|
- assert _JobManager._is_deletable(job.id)
|
|
|
-
|
|
|
- job.blocked()
|
|
|
- assert job.is_blocked()
|
|
|
- assert not _JobManager._is_deletable(job)
|
|
|
- assert not _JobManager._is_deletable(job.id)
|
|
|
-
|
|
|
- job.running()
|
|
|
- assert job.is_running()
|
|
|
- assert not _JobManager._is_deletable(job)
|
|
|
- assert not _JobManager._is_deletable(job.id)
|
|
|
-
|
|
|
- job.pending()
|
|
|
- assert job.is_pending()
|
|
|
- assert not _JobManager._is_deletable(job)
|
|
|
- assert not _JobManager._is_deletable(job.id)
|
|
|
-
|
|
|
- job.status = Status.SUBMITTED
|
|
|
- assert job.is_submitted()
|
|
|
- assert not _JobManager._is_deletable(job)
|
|
|
- assert not _JobManager._is_deletable(job.id)
|
|
|
-
|
|
|
def test_is_deletable():
|
|
|
assert len(_JobManager._get_all()) == 0
|
|
|
task = _create_task(print, 0, "task")
|