Skip to content

Commit

Permalink
updates to marine weather loader
Browse files Browse the repository at this point in the history
  • Loading branch information
Dukestep committed Sep 26, 2024
1 parent 9216827 commit 4105411
Show file tree
Hide file tree
Showing 2 changed files with 4 additions and 2 deletions.
2 changes: 1 addition & 1 deletion deploy/default/sarracenia/marine_weather.conf
Original file line number Diff line number Diff line change
Expand Up @@ -2,7 +2,7 @@ broker amqps://anonymous:[email protected]
queue_name q_${BROKER_USER}.${PROGRAM}.${CONFIG}.${HOSTNAME}
directory /data/geomet/feeds/hpfx
instances 2
subtopic *.WXO-DD.marine.weather.xml.#
subtopic *.WXO-DD.marine_weather.xml.#
mirror True
discard True
reject .*regionList.xml
Expand Down
4 changes: 3 additions & 1 deletion msc_pygeoapi/loader/marine_weather_realtime.py
Original file line number Diff line number Diff line change
Expand Up @@ -53,6 +53,8 @@
# index settings
INDEX_NAME = 'marine_weather_{}'

FORECAST_POLYGONS_WATER_ES_INDEX = 'forecast_polygons_water_hybrid'

MAPPINGS = {
'regular-forecasts': {
'issued_datetime_utc': {
Expand Down Expand Up @@ -405,7 +407,7 @@ def set_area_info(self):

try:
result = self.conn.Elasticsearch.get(
index='forecast_polygons_water_detail',
index=FORECAST_POLYGONS_WATER_ES_INDEX,
id=forecast_id,
_source=['geometry'],
)
Expand Down

0 comments on commit 4105411

Please sign in to comment.