airflow.providers.databricks.assets.databricks

Classes

UnityTableIdentity

Static identity of a Unity Catalog table in one Databricks workspace.

Functions

sanitize_uri(uri)

create_asset(*, host, catalog, 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.databricks.assets.databricks.sanitize_uri(uri)[source]
airflow.providers.databricks.assets.databricks.create_asset(*, host, catalog, schema, table, port=None, extra=None)[source]
class airflow.providers.databricks.assets.databricks.UnityTableIdentity[source]

Static identity of a Unity Catalog table in one Databricks workspace.

Parameters:

  • host – Workspace hostname. A URL such as https://xx.cloud.databricks.com is reduced to its hostname, as the Databricks connection does.

  • catalog – Unity Catalog catalog name.

  • schema – Schema name inside catalog.

  • table – Table name inside schema.

host: str[source]
catalog: str[source]
schema: str[source]
table: str[source]
__post_init__()[source]
to_asset()[source]
airflow.providers.databricks.assets.databricks.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?