diff --git a/dag_hvb_dashboard_etl_1.py b/dag_hvb_dashboard_etl_1.py index 10777c3..3e27be8 100644 --- a/dag_hvb_dashboard_etl_1.py +++ b/dag_hvb_dashboard_etl_1.py @@ -76,7 +76,7 @@ Variables: hvb_nextcloud_ordner = Hans van Bebber (optional, Default s.u.) hvb_geo_cache = /data/etl_cache/geo_plz_koordinaten.csv hvb_log_pfad = /data/etl_cache/etl_laufprotokoll.csv - hvb_skripte_pfad = /opt/airflow/include/hvb (Ablageort der 2 Skripte) + hvb_skripte_pfad = /opt/airflow/git/current/include (Ablageort der 2 Skripte) Dashboard-Tabellen im Prod-Schema 'dashboard' (zusätzlich zu den Daten): etl_metadaten 1 Zeile: geladen_am, Dateianzahl + neuester Stand @@ -411,7 +411,7 @@ def hvb_dashboard_etl(): """ run_pfad = Path(run_dir) skripte = Path(Variable.get("hvb_skripte_pfad", - default_var="/opt/airflow/include/hvb")) + default_var="/opt/airflow/git/current/include")) cache = Path(Variable.get("hvb_geo_cache", default_var="/data/etl_cache/geo_plz_koordinaten.csv")) ziel = run_pfad / "output" / "geo_plz_koordinaten.csv" @@ -464,7 +464,7 @@ def hvb_dashboard_etl(): """ run_pfad = Path(run_dir) skripte = Path(Variable.get("hvb_skripte_pfad", - default_var="/opt/airflow/include/hvb")) + default_var="/opt/airflow/git/current/include")) shutil.copy2(skripte / SKRIPT_ETL, run_pfad / SKRIPT_ETL) ergebnis = subprocess.run( diff --git a/include/hvb/01_geodaten_holen.py b/include/01_geodaten_holen.py similarity index 100% rename from include/hvb/01_geodaten_holen.py rename to include/01_geodaten_holen.py