Skip to content

Commit 0261c73

Browse files
Khushboo Bhatiacognifloyd
Khushboo Bhatia
authored andcommitted
Ignore MemberAlreadyExist exception during startup.
1 parent dfab25a commit 0261c73

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

st2common/st2common/service_setup.py

+5-1
Original file line numberDiff line numberDiff line change
@@ -31,6 +31,7 @@
3131
from tooz.coordination import GroupAlreadyExist
3232
from tooz.coordination import GroupNotCreated
3333
from tooz.coordination import MemberNotJoined
34+
from tooz.coordination import MemberAlreadyExist
3435

3536
from st2common import log as logging
3637
from st2common.constants.logging import DEFAULT_LOGGING_CONF_PATH
@@ -341,7 +342,10 @@ def register_service_in_service_registry(service, capabilities=None, start_heart
341342
'Joining service registry group "%s" as member_id "%s" with capabilities "%s"'
342343
% (group_id, member_id, capabilities)
343344
)
344-
return coordinator.join_group(group_id, capabilities=capabilities).get()
345+
try:
346+
return coordinator.join_group(group_id, capabilities=capabilities).get()
347+
except MemberAlreadyExist:
348+
pass
345349

346350

347351
def deregister_service(service, start_heart=True):

0 commit comments

Comments
 (0)