@@ -58,11 +58,7 @@ def test_register_job_with_non_existing_cluster(ws, admin_locator) -> None:
58
58
]
59
59
60
60
61
- def test_register_job_with_existing_job_cluster_key (
62
- ws ,
63
- mock_path_lookup ,
64
- admin_locator ,
65
- ) -> None :
61
+ def test_register_job_with_existing_job_cluster_key (ws , admin_locator ) -> None :
66
62
"""Register a job with a task referencing a existing job cluster."""
67
63
job_cluster = jobs .JobCluster ("existing-id" , ClusterSpec ())
68
64
task = jobs .Task (task_key = "test-task" , job_cluster_key = "existing-id" )
@@ -75,11 +71,7 @@ def test_register_job_with_existing_job_cluster_key(
75
71
assert not maybe_node .failed
76
72
77
73
78
- def test_register_job_with_non_existing_job_cluster_key (
79
- ws ,
80
- mock_path_lookup ,
81
- admin_locator ,
82
- ) -> None :
74
+ def test_register_job_with_non_existing_job_cluster_key (ws , admin_locator ) -> None :
83
75
"""Register a job with a task referencing a non-existing job cluster."""
84
76
task = jobs .Task (task_key = "test-task" , job_cluster_key = "non-existing-id" )
85
77
settings = jobs .JobSettings (name = "test-job" , tasks = [task ])
@@ -98,12 +90,7 @@ def test_register_job_with_non_existing_job_cluster_key(
98
90
]
99
91
100
92
101
- def test_register_job_with_new_cluster (
102
- ws ,
103
- simple_dependency_resolver ,
104
- mock_path_lookup ,
105
- admin_locator ,
106
- ) -> None :
93
+ def test_register_job_with_new_cluster (ws , admin_locator ) -> None :
107
94
"""Register a job with a task with a new cluster definition."""
108
95
task = jobs .Task (task_key = "test-task" , new_cluster = ClusterSpec ())
109
96
settings = jobs .JobSettings (name = "test-job" , tasks = [task ])
@@ -116,9 +103,7 @@ def test_register_job_with_new_cluster(
116
103
assert not maybe_node .failed
117
104
118
105
119
- def test_sequence_steps_from_job_task_with_existing_cluster_id (
120
- ws , simple_dependency_resolver , mock_path_lookup , admin_locator
121
- ) -> None :
106
+ def test_sequence_steps_from_job_task_with_existing_cluster_id (ws , admin_locator ) -> None :
122
107
"""Sequence a job with a task referencing an existing cluster.
123
108
124
109
Sequence:
@@ -176,9 +161,7 @@ def get_cluster(cluster_id: str) -> ClusterDetails:
176
161
]
177
162
178
163
179
- def test_sequence_steps_from_job_task_with_existing_job_cluster_key (
180
- ws , simple_dependency_resolver , mock_path_lookup , admin_locator
181
- ) -> None :
164
+ def test_sequence_steps_from_job_task_with_existing_job_cluster_key (ws , admin_locator ) -> None :
182
165
"""Sequence a job with a task referencing an existing job cluster.
183
166
184
167
Sequence:
@@ -226,9 +209,7 @@ def test_sequence_steps_from_job_task_with_existing_job_cluster_key(
226
209
]
227
210
228
211
229
- def test_sequence_steps_from_job_task_with_new_cluster (
230
- ws , simple_dependency_resolver , mock_path_lookup , admin_locator
231
- ) -> None :
212
+ def test_sequence_steps_from_job_task_with_new_cluster (ws , admin_locator ) -> None :
232
213
"""Sequence a job with a task that has a new cluster definition.
233
214
234
215
Sequence:
@@ -265,9 +246,7 @@ def test_sequence_steps_from_job_task_with_new_cluster(
265
246
]
266
247
267
248
268
- def test_sequence_steps_from_job_task_with_non_existing_cluster (
269
- ws , simple_dependency_resolver , mock_path_lookup , admin_locator
270
- ) -> None :
249
+ def test_sequence_steps_from_job_task_with_non_existing_cluster (ws , admin_locator ) -> None :
271
250
"""Sequence a job with a task that references a non-existing cluster.
272
251
273
252
Sequence:
0 commit comments