Hello World

This simple workflow calls a task that returns “Hello World” and then just sets that as the final output of the workflow.

import typing

from flytekit import task, workflow


# You can change the signature of the workflow to take in an argument like this:
# def say_hello(name: str) -> str:
@task
def say_hello() -> str:
    return "hello world"

You can treat the outputs of a task as you normally would a Python function. Assign the output to two variables and use them in subsequent tasks as normal. See flytekit.workflow() You can change the signature of the workflow to take in an argument like this: def my_wf(name: str) -> str:

@workflow
def my_wf() -> str:
    res = say_hello()
    return res

Execute the Workflow, simply by invoking it like a function and passing in the necessary parameters

Note

One thing to remember, currently we only support Keyword arguments. So every argument should be passed in the form arg=value. Failure to do so will result in an error

if __name__ == "__main__":
    print(f"Running my_wf() {my_wf()}")

In the next few examples you’ll learn more about the core ideas of Flyte, which are tasks, workflows, and launch plans.