Quick reference¶

Turn a function into a outflow task¶

Let’s say you have this function :

def do_stuff():
    # some computation

To turn this function into a outflow task, you only need to add the @as_task decorator :

@as_task
def DoStuff():
    # some computation

The decorator @as_task turns a function into a class so it may be better to use the class naming convention here

Specifying the outputs of a task¶

Tasks usually return some data for the next task. You have two choices to define the outputs of your tasks :

Recommended: return annotation¶

@Target.output("returned_data")
@as_task
def DoStuff() -> {"returned_data": int}:
    ret = #some computation
    return {
        "returned_data": ret
    }

Alternative way: Target.output decorator¶

@Target.output("returned_data", type=int)
@as_task
def DoStuff():
    ret = #some computation
    return {
        "returned_data": ret
    }