Version v0.4.0 of the documentation is no longer actively maintained. The site that you are currently viewing is an archived snapshot. For up-to-date documentation, see the latest version.
Python runtime API
The leoflow_runtime package runs your task callable inside the container and
bridges its return value to XCom. It is installed in the DAG image (and the dev
venv); your dag.py uses the Apache Airflow Task SDK (from airflow.sdk import DAG, task), and the agent invokes leoflow_runtime to execute the callable.
The full docstring reference (every module, class, and function) is rendered from
source by pdoc and published as a self-contained subsite:
It is a sidecar: pdoc’s output does not share this site’s Docsy theming, so it
is served verbatim under /python-api/ and linked (not embedded) from here. The
generator is website/scripts/gen-python.sh, run on every build so the reference
never drifts from the package.
Modules documented there:
leoflow_runtime— the package entry points (run,xcom_pull).leoflow_runtime.runner— executes the task callable and captures its result.leoflow_runtime.xcom— reads and writes XCom from inside the task container.leoflow_runtime.dbt— the dbt adapter bridge.