Secure your code as it's written. Use Snyk Code to scan source code in minutes - no build needed - and fix issues immediately.
def __init__(self, dag):
self.dag = dag
self.dbnd_airflow_name = {}
config_store = self.get_and_process_dbnd_dag_config()
with dbnd_config(
config_values=config_store, source="airflow"
) as current_config:
self.dbnd_context = DatabandContext(name="airflow__%s" % self.dag.dag_id)
with DatabandContext.context(_context=self.dbnd_context):
# we need databand context to update config first
self.dbnd_config_layer = current_config.config_layer