mirror of
https://github.com/hatchet-dev/hatchet.git
synced 2025-12-29 12:49:45 -06:00
8e80faf2d6
* api changes * doc changes * move docs * generated * generate * pkg * backmerge main * revert to main * revert main * race? * remove go tests
15 lines
406 B
Python
15 lines
406 B
Python
import pytest
|
|
|
|
from examples.dag.worker import dag_workflow
|
|
from hatchet_sdk import Hatchet
|
|
|
|
|
|
@pytest.mark.asyncio(loop_scope="session")
|
|
async def test_run(hatchet: Hatchet) -> None:
|
|
result = await dag_workflow.aio_run()
|
|
|
|
one = result["step1"]["random_number"]
|
|
two = result["step2"]["random_number"]
|
|
assert result["step3"]["sum"] == one + two
|
|
assert result["step4"]["step4"] == "step4"
|