Flytekit Python is the Python SDK built on top of Flyte
Flytekit Python is the Python Library for easily authoring, testing, deploying, and interacting with Flyte tasks, workflows, and launch plans.
If you haven't explored Flyte yet, please refer to:
Flytekit is the core extensible library to author Flyte workflows and tasks and interact with Flyte backend services.
pip install flytekit
from flytekit import task, workflow
@task(cache=True, cache_version="1", retries=3)
def sum(x: int, y: int) -> int:
return x + y
@task(cache=True, cache_version="1", retries=3)
def square(z: int) -> int:
return z*z
@workflow
def my_workflow(x: int, y: int) -> int:
return sum(x=square(z=x), y=square(z=y))
You can find the detailed contribution guide here. Plugins' contribution guide is included as well.
Please see the contributor's guide for a quick summary of how this code is structured.
Refer to the issues section in the contribution guide if you'd like to file an issue.
Refer to plugins/README.md for a list of available plugins. There may be plugins outside of this list, but this list is maintained by the core maintainers.