From 4105411ff324206932aae601b4829bf33cc40a18 Mon Sep 17 00:00:00 2001 From: Etienne Pelletier Date: Tue, 26 Mar 2024 18:10:25 +0000 Subject: [PATCH] updates to marine weather loader --- deploy/default/sarracenia/marine_weather.conf | 2 +- msc_pygeoapi/loader/marine_weather_realtime.py | 4 +++- 2 files changed, 4 insertions(+), 2 deletions(-) diff --git a/deploy/default/sarracenia/marine_weather.conf b/deploy/default/sarracenia/marine_weather.conf index 65417588..b6df1064 100644 --- a/deploy/default/sarracenia/marine_weather.conf +++ b/deploy/default/sarracenia/marine_weather.conf @@ -2,7 +2,7 @@ broker amqps://anonymous:anonymous@hpfx.collab.science.gc.ca 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 diff --git a/msc_pygeoapi/loader/marine_weather_realtime.py b/msc_pygeoapi/loader/marine_weather_realtime.py index 2b7f0101..5156690d 100644 --- a/msc_pygeoapi/loader/marine_weather_realtime.py +++ b/msc_pygeoapi/loader/marine_weather_realtime.py @@ -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': { @@ -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'], )