diff --git a/dag_hvb_dashboard_etl_1.py b/dag_hvb_dashboard_etl_1.py index 3e27be8..3c32fe5 100644 --- a/dag_hvb_dashboard_etl_1.py +++ b/dag_hvb_dashboard_etl_1.py @@ -74,8 +74,8 @@ Connection "duckdb_postgres" (Typ Postgres) — pg_duckdb-Server: 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_geo_cache = /opt/airflow/git/current/etl_cache/geo_plz_koordinaten.csv + hvb_log_pfad = /opt/airflow/git/current/etl_cache/etl_laufprotokoll.csv hvb_skripte_pfad = /opt/airflow/git/current/include (Ablageort der 2 Skripte) Dashboard-Tabellen im Prod-Schema 'dashboard' (zusätzlich zu den Daten): @@ -193,7 +193,7 @@ LOG_SPALTEN = [ def _log_pfad() -> Path: return Path(Variable.get( "hvb_log_pfad", - default_var="/data/etl_cache/etl_laufprotokoll.csv", + default_var="/opt/airflow/git/current/etl_cache/etl_laufprotokoll.csv", )) @@ -413,7 +413,7 @@ def hvb_dashboard_etl(): skripte = Path(Variable.get("hvb_skripte_pfad", default_var="/opt/airflow/git/current/include")) cache = Path(Variable.get("hvb_geo_cache", - default_var="/data/etl_cache/geo_plz_koordinaten.csv")) + default_var="/opt/airflow/git/current/etl_cache/geo_plz_koordinaten.csv")) ziel = run_pfad / "output" / "geo_plz_koordinaten.csv" ziel.parent.mkdir(exist_ok=True)