diff --git a/src/wf_core/runtime/input_sources.py b/src/wf_core/runtime/input_sources.py index 7f9b80c3..f5d7808e 100644 --- a/src/wf_core/runtime/input_sources.py +++ b/src/wf_core/runtime/input_sources.py @@ -226,4 +226,3 @@ def resolve_schedule_input_bindings( except LocalPathError as exc: raise WorkflowExecutionError(f"{label} {location}: {exc}") from exc return payload - diff --git a/tests/scheduling/test_history_reconcile.py b/tests/scheduling/test_history_reconcile.py index 30d54d13..ef3d092d 100644 --- a/tests/scheduling/test_history_reconcile.py +++ b/tests/scheduling/test_history_reconcile.py @@ -211,9 +211,12 @@ def test_interval_identity_rejects_naive_or_half_specified_bounds( def test_history_identity_without_interval_still_uses_created_time() -> None: created = datetime(2026, 9, 8, 14, 0, tzinfo=UTC) - assert entry_occurrence_id( - HistoryEntry(schedule_id="a", kind="interval-summary"), created - ) == "a|summary|2026-09-08T14:00:00+00:00" + assert ( + entry_occurrence_id( + HistoryEntry(schedule_id="a", kind="interval-summary"), created + ) + == "a|summary|2026-09-08T14:00:00+00:00" + ) def test_failed_run_persists_reason_without_callback(tmp_path: Path) -> None: diff --git a/tests/wf_api/test_schedules.py b/tests/wf_api/test_schedules.py index 998e26bd..23365ee0 100644 --- a/tests/wf_api/test_schedules.py +++ b/tests/wf_api/test_schedules.py @@ -527,9 +527,7 @@ async def test_update_stale_revision_rejected(tmp_path: Path) -> None: async def test_admin_mutation_waits_for_poll_transaction(tmp_path: Path) -> None: """A poll transition and an API edit cannot interleave store writes.""" - api, sched_store, run_store, artifact_store, _ = _harness( - tmp_path / "admin_poll" - ) + api, sched_store, run_store, artifact_store, _ = _harness(tmp_path / "admin_poll") await api.create_schedule( schedule_id="s", deployment_id="dep.personal", trigger=_cron() ) diff --git a/tests/wf_transport_rpc_http/test_rpc_models.py b/tests/wf_transport_rpc_http/test_rpc_models.py index 474f4911..0b33f2d6 100644 --- a/tests/wf_transport_rpc_http/test_rpc_models.py +++ b/tests/wf_transport_rpc_http/test_rpc_models.py @@ -97,9 +97,7 @@ def test_update_schedule_params_match_create_numeric_constraints() -> None: ) for revision in (0, -1): with pytest.raises(ValidationError): - UpdateScheduleParams( - schedule_id="schedule", expected_revision=revision - ) + UpdateScheduleParams(schedule_id="schedule", expected_revision=revision) def test_schedule_policy_params_reject_unknown_values() -> None: