Flyte

Write plain, async-native Python that orchestrates agents, data and ML pipelines, and inference — with the durability, reproducibility, and observability that production demands.

• 🤖 Dynamic, agent-native execution — Write or generate orchestration logic that adapts on the fly at runtime. Loops, conditionals, fan-outs, and LLM-driven control flow are just Python.
• 🛡️ Durable, self-healing workflows — Flyte 2 is infrastructure-aware, automatically recovering from both logic and infrastructure failures like OOM crashes. Every execution is logged, reproducible, and observable from a single UI.
• ⚡ Realtime and batch inference — Flyte 2 handles inference natively, no separate serving stack required.

# pip install flyteimportflyteenv=flyte.TaskEnvironment(name="hello")
@env.taskasyncdefhello(name: str) ->str:
returnf"Hello, {name}!"if__name__=="__main__":
flyte.init_from_config()
run=flyte.run(hello, name="world")
print(run.url)

Show us some ❤️ by starring flyteorg/flyte!