This commit is contained in:
Aryan Singh committed 2026-09-26 02:27:42 -05:00
1 parent 611a86830e
commit c230859549
1 file changed
+2 -1
+2 -1
View File
@@ -131,11 +131,12 @@ def worker_1():
incoming_state = member['state'] incoming_state = member['state']
incoming_hb = member['heart_beat'] incoming_hb = member['heart_beat']
local_member = members_list[member_id] local_member = members_list.get(member_id)
if local_member is None: if local_member is None:
if incoming_state == "failed": if incoming_state == "failed":
dead_members.add(member_id) dead_members.add(member_id)
continue
else: else:
members_list[member_id] = { members_list[member_id] = {
"heart_beat": incoming_hb, "heart_beat": incoming_hb,