Skip to content

Commit 2f59157

Browse files
Rup-Narayan-Rajbanshiranjan-stha
authored andcommitted
fix(gdacs): Remove hazard detail from impact item
- Add severity data to event item.
1 parent af4e23f commit 2f59157

File tree

1 file changed

+5
-4
lines changed

1 file changed

+5
-4
lines changed

pystac_monty/sources/gdacs.py

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -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

Comments
 (0)