Update covid infections url according to rki github changes.

rocs-org · Oct 13, 2022 · ca45137 · ca45137
1 parent 294f471
commit ca45137
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/services/airflow/src/dags/corona_cases/cases/etl.py b/services/airflow/src/dags/corona_cases/cases/etl.py
@@ -9,7 +9,7 @@
 from src.lib.test_helpers import set_env_variable_from_dag_config_if_present
 
 
-URL = "https://github.com/robert-koch-institut/SARS-CoV-2_Infektionen_in_Deutschland/blob/master/Aktuell_Deutschland_SarsCov2_Infektionen.csv?raw=true"  # noqa: E501
+URL = f"https://github.com/robert-koch-institut/SARS-CoV-2-Infektionen_in_Deutschland/blob/main/Aktuell_Deutschland_SarsCov2_Infektionen.csv?raw=true"  # noqa: E501
 SCHEMA = "coronacases"
 TABLE = "german_counties_more_info"
 
@@ -18,6 +18,7 @@
 
 @curry
 def etl_covid_cases(url: str, schema: str, table: str, **kwargs) -> DBContext:
+    print(url)
     return R.pipe(
         set_env_variable_from_dag_config_if_present("TARGET_DB"),
         lambda *args: download_csv(url),