Most of my flows don’t have dependency arrows,
I’m using python async to run async flows which use pydantic models as variables, everything runs smoothly but the arrows are missing.
For example:
(I’m on my phone so this is a simplified version of my flow)
Copy code
class A(BaseModel):
a: int
@task
async def my_task() -> A:
return A(1)
@task
async def my_second_task(a: A) -> None:
print(a)
@flow
async def my_flow():
a = await my_task()
await my_second_task(a)
I expect a dependency arrows to show between my_task and my_second_task.
Bring your towel and join one of the fastest growing data communities. Welcome to our second-generation open source orchestration platform, a completely rethought approach to dataflow automation.