Max Jackson
@task(key=value)
class MyNewTask(Task): def run(): pass
Kevin Kho
mnt = MyNewTask(key=value) with Flow(..) as flow: mnt()
**kwargs
super.init()
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.