Skip to content

Commit d760c5e

Browse files
committed
Test sequence job with task dependency
1 parent 553f181 commit d760c5e

File tree

1 file changed

+18
-0
lines changed

1 file changed

+18
-0
lines changed

tests/unit/assessment/test_sequencing.py

Lines changed: 18 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -103,6 +103,24 @@ def test_register_job_with_new_cluster(ws, admin_locator) -> None:
103103
assert not maybe_node.failed
104104

105105

106+
def test_register_job_with_task_dependency(ws, admin_locator) -> None:
107+
"""Register a job with two tasks having a dependency."""
108+
task1 = jobs.Task(task_key="task1")
109+
task_dependency = jobs.TaskDependency(task1.task_key)
110+
task2 = jobs.Task(task_key="task2", depends_on=[task_dependency])
111+
tasks = [task2, task1] # Reverse order on purpose to test if this is handled
112+
settings = jobs.JobSettings(name="job", tasks=tasks)
113+
job = jobs.Job(job_id=1234, settings=settings)
114+
sequencer = MigrationSequencer(ws, admin_locator)
115+
116+
maybe_job_node = sequencer.register_job(job)
117+
maybe_node = sequencer.register_job(job)
118+
119+
assert not maybe_node.failed
120+
121+
assert not maybe_job_node.failed
122+
123+
106124
def test_sequence_steps_from_job_task_with_existing_cluster_id(ws, admin_locator) -> None:
107125
"""Sequence a job with a task referencing an existing cluster.
108126

0 commit comments

Comments
 (0)