This commit is contained in:
Nuno Campos
2025-01-16 09:55:04 -08:00
parent 8c88e203bc
commit a16def5140
@@ -6281,6 +6281,7 @@ async def test_interrupt_loop(checkpointer_name: str):
]
@NEEDS_CONTEXTVARS
@pytest.mark.parametrize("checkpointer_name", ALL_CHECKPOINTERS_ASYNC)
async def test_interrupt_functional(checkpointer_name: str) -> None:
@task
@@ -6309,6 +6310,7 @@ async def test_interrupt_functional(checkpointer_name: str) -> None:
assert res == {"a": "foobar", "b": "bar"}
@NEEDS_CONTEXTVARS
@pytest.mark.parametrize("checkpointer_name", ALL_CHECKPOINTERS_ASYNC)
async def test_interrupt_task_functional(checkpointer_name: str) -> None:
@task