Skip to content

Commit

Permalink
format
Browse files Browse the repository at this point in the history
  • Loading branch information
chenkovsky authored and eladkal committed Jan 23, 2025
1 parent 6b989c1 commit 1fe14b5
Showing 1 changed file with 4 additions and 8 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -711,7 +711,8 @@ def test_find_custom_pod_labels(
mock_await_pod_start,
mock_await_pod_completion,
mock_fetch_requested_container_logs,
data_file,):
data_file,
):
task_name = "test_find_custom_pod_labels"
job_spec = yaml.safe_load(data_file("spark/application_template.yaml").read_text())

Expand All @@ -724,14 +725,9 @@ def test_find_custom_pod_labels(
)
context = create_context(op)
op.execute(context)
label_selector = (
op._build_find_pod_label_selector(context)
+ ",spark-role=driver"
)
label_selector = op._build_find_pod_label_selector(context) + ",spark-role=driver"
op.find_spark_job(context)
mock_get_kube_client.list_namespaced_pod.assert_called_with(
'default', label_selector=label_selector
)
mock_get_kube_client.list_namespaced_pod.assert_called_with("default", label_selector=label_selector)


@pytest.mark.db_test
Expand Down

0 comments on commit 1fe14b5

Please sign in to comment.