airflow.providers.common.io.datasets.file

Module Contents

Functions

create_dataset(*, path[, extra])

sanitize_uri(uri)

convert_dataset_to_openlineage(dataset, lineage_context)

Translate Dataset with valid AIP-60 uri to OpenLineage with assistance from the context.

airflow.providers.common.io.datasets.file.create_dataset(*, path, extra=None)[source]
airflow.providers.common.io.datasets.file.sanitize_uri(uri)[source]
airflow.providers.common.io.datasets.file.convert_dataset_to_openlineage(dataset, lineage_context)[source]

Translate Dataset with valid AIP-60 uri to OpenLineage with assistance from the context.

Windows paths are not standardized and can produce unexpected behaviour.

Was this entry helpful?