airflow.providers.vertica.assets.vertica

Functions

sanitize_uri(uri)

create_asset(*, host, database, schema, table[, port, ...])

convert_asset_to_openlineage(asset, lineage_context)

Translate Asset with valid AIP-60 uri to OpenLineage with assistance from the hook.

Module Contents

airflow.providers.vertica.assets.vertica.sanitize_uri(uri)[source]
airflow.providers.vertica.assets.vertica.create_asset(*, host, database, schema, table, port=5433, extra=None)[source]
airflow.providers.vertica.assets.vertica.convert_asset_to_openlineage(asset, lineage_context)[source]

Translate Asset with valid AIP-60 uri to OpenLineage with assistance from the hook.

Was this entry helpful?