@@ -143,7 +143,7 @@ def get_stac_items_from_memory(self) -> typing.Generator[Item, None, None]:
143143 episode_geometry_data = (validated_geometry_data , geometry_data_url ),
144144 )
145145 yield episode_hazard_item
146- yield from self .make_impact_items (episode_hazard_item , validated_episode_data )
146+ yield from self .make_impact_items (source_event_item , validated_episode_data )
147147 except Exception :
148148 self .transform_summary .increment_failed_rows (1 )
149149 logger .warning ("Failed to process the GDACS data" , exc_info = True )
@@ -182,7 +182,7 @@ def get_stac_items_from_file(self) -> typing.Generator[Item, None, None]:
182182 episode_geometry_data = (validated_geometry_data , geometry_data_url ),
183183 )
184184 yield episode_hazard_item
185- yield from self .make_impact_items (episode_hazard_item , validated_episode_data )
185+ yield from self .make_impact_items (source_event_item , validated_episode_data )
186186 except Exception :
187187 self .transform_summary .increment_failed_rows (1 )
188188 logger .warning ("Failed to process the GDACS data" , exc_info = True )
@@ -259,6 +259,7 @@ def make_source_event_item(self, data: GdacsEventDataValidator, source_url: str)
259259 "description" : description ,
260260 "start_datetime" : startdate .isoformat (),
261261 "end_datetime" : enddate .isoformat (),
262+ "severitydata" : data .properties .severitydata .model_dump (),
262263 },
263264 )
264265
@@ -361,15 +362,15 @@ def get_hazard_detail(self, data: GdacsEventDataValidator) -> HazardDetail:
361362 estimate_type = MontyEstimateType .PRIMARY ,
362363 )
363364
364- def make_impact_items (self , hazard_item : Item , data : GdacsEventDataValidator ) -> list [Item ]:
365+ def make_impact_items (self , event_item : Item , data : GdacsEventDataValidator ) -> list [Item ]:
365366 impact_items = []
366367
367368 # Search for Sendai fields
368369 if hasattr (data .properties , "sendai" ):
369370 sendai = data .properties .sendai
370371 if sendai :
371372 for entry in sendai :
372- impact_item = self .make_impact_item_from_sendai_entry (entry , hazard_item , data = data )
373+ impact_item = self .make_impact_item_from_sendai_entry (entry , event_item , data = data )
373374 impact_items .append (impact_item )
374375
375376 return impact_items
0 commit comments