Openlineage Prefect

Basic Configuration

At a minimum, define a namespace, Prefect API URL and transport consisting of a type, URL and endpoint. All three can be supplied using environment variables.

For example:

export OPENLINEAGE_NAMESPACE='prefect_test' &&
export OPENLINEAGE__TRANSPORT__TYPE='http' &&
export OPENLINEAGE__TRANSPORT__URL='http://lineageconsumer.com:5000' &&
export OPENLINEAGE__TRANSPORT__ENDPOINT='/api/v1/lineage' &&
export PREFECT_API_URL='http://prefecthost.com:4200/api'

For more details about OpenLineage transport options and how to configure them, consult the OpenLineage Python Client Documentation.

Execution

Import the openlineage_prefect package and execute collect_and_process_runs() asynchronously in its own process.

For example:

import asyncio
import openlineage_prefect
from openlineage_prefect.prefect_adapter.listener import PrefectOpenLineageListener

async def main():
    await PrefectOpenLineageListener().collect_and_process_runs()

if __name__ == "__main__":
    asyncio.run(main())

Datasets

The integration looks for datasets in Prefect Artifacts. To attach input and output datasets to job runs, use create_table_artifact() from the Artifact library. Provide a namespace, typically the dataset URI, and name to the adapter via an artifact's table and description, respectively. Distinguish the type of dataset by appending _output or _input to the description.

For example:

ol_table = [{"database_uri":"duckdb:///customers_db", "table":"customers"}]

create_table_artifact(
    key="upstream-insert",
    table=ol_table,
    description="ol-dataset_output"
)

Metadata

Release files for openlineage-prefect 0.0.1b6

For a detailed explanation of source distributions (sdists) and built distributions (wheels), please see the package formats documentation.

Source distribution (sdist)

Source distribution for openlineage-prefect 0.0.1b6
File	Size	Uploaded
openlineage_prefect-0.0.1b6.tar.gz	7.1 kB	Sep 26, 2026	Details

Built distribution (wheel)

Table of built distributions (wheels) for openlineage-prefect 0.0.1b6
File	Interpreter	ABI	Platform	Reset
openlineage_prefect-0.0.1b6-py3-none-any.whl 10.1 kB Sep 26, 2026	Python 3	none	any	Details

Total release size: 17.2 kB

Release files / openlineage_prefect-0.0.1b6.tar.gz

Download URL	openlineage_prefect-0.0.1b6.tar.gz
Size	7.1 kB
Tags	Source
SHA-256 checksum How to use checksums	`cdaae04c0ebd4790d520d00efc55d858d741dd01d311ba81f82f6475c784c55d`
BLAKE2b-256 checksum How to use checksums	`dca54d33e5e8b40a61d033c7d43ed5fd3e530c1a1efe88113d63d04a0adf225c`
Upload date	Sep 26, 2026
Uploaded using Trusted Publishing? What is trusted publishing?	No
Uploaded via	`twine/7.0.0 CPython/3.12.14`

Release files / openlineage_prefect-0.0.1b6-py3-none-any.whl

Download URL	openlineage_prefect-0.0.1b6-py3-none-any.whl
Size	10.1 kB
Tags	Python 3
SHA-256 checksum How to use checksums	`1875c7ef9ef394f68ebc95448c5c570af392febaf272a210975e86887a2d0766`
BLAKE2b-256 checksum How to use checksums	`7b9082c25ca21fd90bc9550c50f8e53bebf1a5d57b03565098fd3273f9b94086`
Upload date	Sep 26, 2026
Uploaded using Trusted Publishing? What is trusted publishing?	No
Uploaded via	`twine/7.0.0 CPython/3.12.14`