Skip to content

Commit bf169c8

Browse files
authored
update group-id for system eraser service (#738)
1 parent e5e4319 commit bf169c8

File tree

2 files changed

+3
-2
lines changed

2 files changed

+3
-2
lines changed

ros/lib/config.py

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -139,6 +139,7 @@ def build_endpoint_url(ep):
139139
REDIS_URL = f"{REDIS_SCHEME}{REDIS_AUTH}{REDIS_HOST}:{REDIS_PORT}"
140140
GROUP_ID = os.getenv('GROUP_ID', 'resource-optimization')
141141
GROUP_ID_SUGGESTIONS_ENGINE = os.getenv('GROUP_ID_SUGGESTIONS_ENGINE', 'suggestions-engine-group')
142+
GROUP_ID_SYSTEM_ERASER = os.getenv('GROUP_ID_SYSTEM_ERASER', 'system-eraser-group')
142143
# The default value for PATH_PREFIX is same as under clowdapp file
143144
PATH_PREFIX = os.getenv("PATH_PREFIX", "/api")
144145
APP_NAME = os.getenv("APP_NAME", "ros")

ros/processor/system_eraser.py

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,7 @@
77
get_logger,
88
METRICS_PORT,
99
INVENTORY_EVENTS_TOPIC,
10-
GROUP_ID_SUGGESTIONS_ENGINE,
10+
GROUP_ID_SYSTEM_ERASER,
1111
POLL_TIMEOUT_SECS
1212
)
1313
from ros.lib import consume
@@ -21,7 +21,7 @@
2121

2222
class SystemEraser:
2323
def __init__(self):
24-
self.consumer = consume.init_consumer(INVENTORY_EVENTS_TOPIC, GROUP_ID_SUGGESTIONS_ENGINE)
24+
self.consumer = consume.init_consumer(INVENTORY_EVENTS_TOPIC, GROUP_ID_SYSTEM_ERASER)
2525
self.service = 'SYSTEM_ERASER'
2626
self.event = 'Delete event'
2727
self.running = True

0 commit comments

Comments
 (0)