lda.chat/lda-wf
2
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

chore: polish interrupt contract implementation

Browse Source
This commit is contained in:
lda
2026-07-01 06:07:45 +07:00 Verified
parent 5dd56d286f
commit 0038a3a3ce
2 changed files with 4 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files
src/wf_core/models/steps.py
+1 -2
View File
@@ -3,9 +3,8 @@ from __future__ import annotations
from collections.abc import Mapping from collections.abc import Mapping
from typing import Annotated, Literal, Self from typing import Annotated, Literal, Self
from pydantic import BaseModel, ConfigDict, Field, field_validator, model_validator
from jsonschema import Draft202012Validator, SchemaError, validators from jsonschema import Draft202012Validator, SchemaError, validators
from pydantic import BaseModel, ConfigDict, Field, field_validator, model_validator
from wf_core.models.conditions import Condition from wf_core.models.conditions import Condition
from wf_core.models.schemas import SchemaRef from wf_core.models.schemas import SchemaRef
tests/core/test_execution_results.py
+3 -1
View File
@@ -184,7 +184,9 @@ async def test_interrupt_resume_payload_validates_before_state_mutation() -> Non
), ),
EndNode(id="end", type="end", outcome="submitted"), EndNode(id="end", type="end", outcome="submitted"),
], ],
edges=[Edge.model_validate({"from": "ask", "outcome": "submitted", "to": "end"})], edges=[
Edge.model_validate({"from": "ask", "outcome": "submitted", "to": "end"})
],
) )
interrupted = await execute_workflow_async(workflow, {}, {}) interrupted = await execute_workflow_async(workflow, {}, {})