Skip to content

Commit

Permalink
fix test
Browse files Browse the repository at this point in the history
  • Loading branch information
sanderegg committed Jul 3, 2023
1 parent 11039c0 commit e12bb89
Showing 1 changed file with 3 additions and 1 deletion.
Original file line number Diff line number Diff line change
Expand Up @@ -435,11 +435,12 @@ async def _assert_schedule_pipeline_PENDING(
mocked_dask_client.send_computation_tasks.assert_has_calls(
calls=[
mock.call(
published_project.project.prj_owner,
user_id=published_project.project.prj_owner,
project_id=published_project.project.uuid,
cluster_id=DEFAULT_CLUSTER_ID,
tasks={f"{p.node_id}": p.image},
callback=scheduler._wake_up_scheduler_now,
metadata=mock.ANY,
)
for p in expected_pending_tasks
],
Expand Down Expand Up @@ -596,6 +597,7 @@ async def _return_random_task_result(job_id) -> TaskOutputData:
f"{next_pending_task.node_id}": next_pending_task.image,
},
callback=scheduler._wake_up_scheduler_now,
metadata=mock.ANY,
)
mocked_dask_client.send_computation_tasks.reset_mock()
mocked_dask_client.get_tasks_status.assert_has_calls(
Expand Down

0 comments on commit e12bb89

Please sign in to comment.