fix: lint and format cleanup
This commit is contained in:
+1
-1
@@ -12,7 +12,6 @@ from wf_artifacts import (
|
|||||||
from wf_core import RunState
|
from wf_core import RunState
|
||||||
|
|
||||||
from .artifact_plans import raw_plan_from_artifact
|
from .artifact_plans import raw_plan_from_artifact
|
||||||
from .run_locks import AsyncKeyedLock
|
|
||||||
from .deployments import WorkflowDeploymentApi, _available_sources
|
from .deployments import WorkflowDeploymentApi, _available_sources
|
||||||
from .next_actions import NextActions
|
from .next_actions import NextActions
|
||||||
from .operation_context import WorkflowOperationContext
|
from .operation_context import WorkflowOperationContext
|
||||||
@@ -25,6 +24,7 @@ from .run_lifecycle import (
|
|||||||
restore_interrupted_run,
|
restore_interrupted_run,
|
||||||
validate_pinned_resume_environment,
|
validate_pinned_resume_environment,
|
||||||
)
|
)
|
||||||
|
from .run_locks import AsyncKeyedLock
|
||||||
from .saved_subgraphs import saved_subgraph_tree_from_snapshots
|
from .saved_subgraphs import saved_subgraph_tree_from_snapshots
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
@@ -280,6 +280,7 @@ def test_handler_delegation_for_inspect_artifact(tmp_path: Path) -> None:
|
|||||||
assert handler_result["version"] == api_result["version"]
|
assert handler_result["version"] == api_result["version"]
|
||||||
assert handler_result["title"] == api_result["title"]
|
assert handler_result["title"] == api_result["title"]
|
||||||
|
|
||||||
|
|
||||||
@pytest.mark.asyncio
|
@pytest.mark.asyncio
|
||||||
async def test_delete_artifact_deletes_unreferenced_version(tmp_path: Path) -> None:
|
async def test_delete_artifact_deletes_unreferenced_version(tmp_path: Path) -> None:
|
||||||
artifact_store = FileWorkflowArtifactStore(tmp_path / "artifacts_delete")
|
artifact_store = FileWorkflowArtifactStore(tmp_path / "artifacts_delete")
|
||||||
@@ -295,6 +296,7 @@ async def test_delete_artifact_deletes_unreferenced_version(tmp_path: Path) -> N
|
|||||||
with pytest.raises(KeyError, match="unknown workflow artifact"):
|
with pytest.raises(KeyError, match="unknown workflow artifact"):
|
||||||
artifact_store.get_artifact("echo", 1)
|
artifact_store.get_artifact("echo", 1)
|
||||||
|
|
||||||
|
|
||||||
@pytest.mark.asyncio
|
@pytest.mark.asyncio
|
||||||
async def test_delete_artifact_rejects_referenced_version(tmp_path: Path) -> None:
|
async def test_delete_artifact_rejects_referenced_version(tmp_path: Path) -> None:
|
||||||
artifact_store = FileWorkflowArtifactStore(tmp_path / "artifacts_delete_blocked")
|
artifact_store = FileWorkflowArtifactStore(tmp_path / "artifacts_delete_blocked")
|
||||||
|
|||||||
@@ -16,7 +16,7 @@ from wf_artifacts import (
|
|||||||
)
|
)
|
||||||
from wf_authoring import NodeSpec
|
from wf_authoring import NodeSpec
|
||||||
from wf_core import InterruptRequest, RunState, RunStatus
|
from wf_core import InterruptRequest, RunState, RunStatus
|
||||||
from wf_platform import CapabilityBuckets, CapabilitySource, SourceKind
|
from wf_platform import CapabilitySource
|
||||||
|
|
||||||
|
|
||||||
class DummyEvents:
|
class DummyEvents:
|
||||||
@@ -174,9 +174,7 @@ def _artifact() -> WorkflowArtifact:
|
|||||||
"output_schema": {"type": "object", "properties": {}},
|
"output_schema": {"type": "object", "properties": {}},
|
||||||
"outcomes": ["ok", "submitted"],
|
"outcomes": ["ok", "submitted"],
|
||||||
"start": "end_submitted",
|
"start": "end_submitted",
|
||||||
"nodes": [
|
"nodes": [{"id": "end_submitted", "type": "end", "outcome": "submitted"}],
|
||||||
{"id": "end_submitted", "type": "end", "outcome": "submitted"}
|
|
||||||
],
|
|
||||||
"edges": [],
|
"edges": [],
|
||||||
},
|
},
|
||||||
)
|
)
|
||||||
|
|||||||
Reference in New Issue
Block a user