Matthew Bell
result
None
@task async def test() -> str: return "I'm an async function" @flow async def main() -> None: future = await test.submit() state = await future.get_state() result = state.result() print(result) if __name__ == "__main__": asyncio.run(main())
@task async def test() -> str: return "I'm an async function" @flow async def main() -> None: future = await test.submit() result = await future.result() state = await future.get_state() print(result) if __name__ == "__main__": asyncio.run(main())
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.