Merge pull request #48 from rodekruis/fix/various

p-phung · web-flow · commit 55cdff7213b5 · 2025-12-11T22:08:06.000+01:00
Fix/various
diff --git a/retrievalpipeline/config/somalia.py b/retrievalpipeline/config/somalia.py
@@ -78,7 +78,7 @@ def drought_data_request(self) -> EcmwfDataRequest:
                         self.datetime_config.recent_start_year, self.datetime_config.recent_end_year + 1
                     )
                 ],
-                "month": ["01", "07"],
+                "month": [f"{m:02d}" for m in range(1, 13)],
                 "time": ["00:00"],
                 "data_format": "netcdf",
                 # "download_format": "zip",
diff --git a/run_pipeline.py b/run_pipeline.py
@@ -81,15 +81,15 @@ def construct_pipeline(run_id: str, iso3: str) -> ETLPipeline:
 
     extractors = [
         ChirpsExtractor(
-            name="Drought Extractor",
+            name="Flood Extractor",
             storage=storage,
             path_to_output=f"{path_to_bronze_global}/chirps/rainfall/",
             data_request=config.chirps_data_request,
         ),
         EcmwfExtractor(
             name="Drought Extractor",
             storage=storage,
-            path_to_output=f"{path_to_bronze}/ecmwf/rainfall/",
+            path_to_output=f"{path_to_bronze}/ecmwf/rainfall/drought.zip",
             data_request=config.drought_data_request,
         ),
         EcmwfExtractor(

Original file line number	Diff line number	Diff line change
`@@ -78,7 +78,7 @@ def drought_data_request(self) -> EcmwfDataRequest:`
`78`	`78`	`self.datetime_config.recent_start_year, self.datetime_config.recent_end_year + 1`
`79`	`79`	`)`
`80`	`80`	`],`
`81`		`- "month": ["01", "07"],`
	`81`	`+ "month": [f"{m:02d}" for m in range(1, 13)],`
`82`	`82`	`"time": ["00:00"],`
`83`	`83`	`"data_format": "netcdf",`
`84`	`84`	`# "download_format": "zip",`