Muhammad Daniyal
def workflow1(): @task def abc(): somelogichere with Flow('one') as f: abc() f.run() @task def xyz(): workflow1() with Flow('main flow') as f: xyz() f.run()
Jason
Kevin Kho
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.