airflow.providers.edge3.models.db

Attributes

PACKAGE_DIR

Classes

EdgeDBManager

Manages Edge3 provider database tables.

Functions

check_db_manager_config()

Warn if EdgeDBManager is not registered to run DB migrations.

Module Contents

airflow.providers.edge3.models.db.PACKAGE_DIR[source]
class airflow.providers.edge3.models.db.EdgeDBManager(session)[source]

Bases: airflow.utils.db_manager.BaseDBManager

Manages Edge3 provider database tables.

metadata[source]
version_table_name = 'alembic_version_edge3'[source]
migration_dir[source]
alembic_file[source]
supports_table_dropping = True[source]
revision_heads_map[source]
initdb()[source]

Initialize the database, handling pre-alembic installations.

If the edge3 tables already exist but the alembic version table does not (e.g. created via create_all before the migration chain was introduced), stamp to the first revision and run the incremental upgrade so every migration is applied rather than jumping straight to head.

drop_tables(connection)[source]

Drop only edge3 tables in reverse dependency order.

airflow.providers.edge3.models.db.check_db_manager_config()[source]

Warn if EdgeDBManager is not registered to run DB migrations.

Should be called whenever the edge3 provider is active so operators are alerted early if the required database configuration is missing.

Was this entry helpful?