airflow.secrets.metastore

Objects relating to sourcing connections from metastore database

Module Contents

class airflow.secrets.metastore.MetastoreBackend[source]

Bases: airflow.secrets.BaseSecretsBackend

Retrieves Connection object from airflow metastore database.

get_connections(self, conn_id, session=None)[source]
get_variable(self, key, session=None)[source]

Get Airflow Variable from Metadata DB

Parameters

  • key (str) – Variable Key

  • session – Sqlalchemy ORM Session

Returns

Variable Value

Was this entry helpful?