Ghgc 632/scheduled worldview nrt collection update

dags/generate_dags.py

@@ -7,19 +7,22 @@
 
 from veda_data_pipeline.veda_discover_pipeline import get_discover_dag
 from veda_data_pipeline.veda_vector_pipeline import get_ingest_vector_dag
+from veda_data_pipeline.veda_wmts2stac_update_pipeline import get_ingest_wmts2stac_dag
 from veda_data_pipeline.veda_pyarc2stac_pipeline import get_ingest_pyarc2stac_dag
 
 dag_generators = {
         "veda_discover":          get_discover_dag,
         "veda_ingest_vector":     get_ingest_vector_dag,
         "veda_pyarc2stac_ingest": get_ingest_pyarc2stac_dag,
+        "veda_wmts2stac_ingest": get_ingest_wmts2stac_dag
     }
 
 # preserve DAG history
 dag_names = {
     "veda_discover": "discover",
     "veda_ingest_vector": "vector",
     "veda_pyarc2stac_ingest": "pyarc2stac",
+    "veda_wmts2stac_ingest": "wmts2stac"
 }
 
 def generate_dags():
@@ -64,7 +67,6 @@ def generate_dags():
                     file_name = id # use id for DAG name if provided, otherwise default to file name
                 dag_generators[dag](id=f"{dag_names[dag]}-{file_name}", event=c)
 
-
 generate_dags()
 # create default DAGs (no config or schedule)
 get_ingest_vector_dag(id="veda_ingest_vector", event={})