diff --git a/tests/integration/test_workers.py b/tests/integration/test_workers.py index 7ffd8b93..5d5c6962 100644 --- a/tests/integration/test_workers.py +++ b/tests/integration/test_workers.py @@ -323,8 +323,11 @@ def test_undefined_additional_stores(worker, job_controller) -> None: == 2 ) - -def test_submit_flow_with_scheduler_username(monkeypatch, job_controller) -> None: +@pytest.mark.parametrize( + "remote_worker_name", + [w for w in WORKERS if "remote" in w], +) +def test_submit_flow_with_scheduler_username(remote_worker_name, monkeypatch, job_controller) -> None: from jobflow import Flow from jobflow_remote import submit_flow @@ -333,7 +336,6 @@ def test_submit_flow_with_scheduler_username(monkeypatch, job_controller) -> Non from jobflow_remote.remote.queue import QueueManager from jobflow_remote.testing import add - remote_worker_name = "test_remote_worker" job = add(1, 1) flow = Flow([job])