initial stage

airflow/dags/import_EOSC_graph.py

@@ -55,7 +55,7 @@ def strip_prefix(s, p):
     start_date=pendulum.datetime(2021, 1, 1, tz="UTC"),
     catchup=False,
     default_args=default_args,
-    tags=["example", "async", "s3"],
+    tags=["lot1"],
 )
 def import_EOSC_graph():
     @task

airflow/dags/import_eosc_catalog.py

@@ -52,7 +52,7 @@ def strip_prefix(s, p):
     start_date=pendulum.datetime(2021, 1, 1, tz="UTC"),
     catchup=False,
     default_args=default_args,
-    tags=["example", "async", "s3"],
+    tags=["lot1"],
 )
 def eosc_catalog_import():
     @task

airflow/dags/import_skg_if.py

@@ -55,7 +55,7 @@ def strip_prefix(s, p):
     start_date=pendulum.datetime(2021, 1, 1, tz="UTC"),
     catchup=False,
     default_args=default_args,
-    tags=["example", "async", "s3"],
+    tags=["lot1"],
 )
 def skg_if_pipeline():
     @task