Skip to content

Commit ae9da90

Browse files
committed
Re-init profanity filter after a DCS update.
1 parent c8c6afd commit ae9da90

File tree

2 files changed

+12
-4
lines changed

2 files changed

+12
-4
lines changed

core/data/impl/nodeimpl.py

Lines changed: 9 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -622,9 +622,16 @@ def run_subprocess() -> int:
622622
await self.get_dcs_branch_and_version()
623623
if rc not in [0, 350]:
624624
return rc
625-
if self.locals['DCS'].get('desanitize', True):
626-
if not self.locals['DCS'].get('cloud', False) or self.master:
625+
# Patch DCS files
626+
if not self.locals['DCS'].get('cloud', False) or self.master:
627+
if self.locals['DCS'].get('desanitize', True):
627628
utils.desanitize(self)
629+
# init profanity filter, if needed
630+
if any(
631+
instance.server.locals.get('profanity_filter', False)
632+
for instance in self.instances if instance.server
633+
):
634+
utils.init_profanity_filter(self)
628635
# call after update hooks
629636
for callback in self.after_update.values():
630637
await callback()

services/servicebus/service.py

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -255,8 +255,9 @@ async def register_local_servers(self):
255255
self.log.info(f"- {num} local DCS servers registered.")
256256

257257
# init profanity filter, if needed
258-
if any(server.locals.get('profanity_filter', False) for server in local_servers):
259-
utils.init_profanity_filter(self.node)
258+
if not self.locals['DCS'].get('cloud', False) or self.master:
259+
if any(server.locals.get('profanity_filter', False) for server in local_servers):
260+
utils.init_profanity_filter(self.node)
260261

261262
async def register_remote_servers(self, node: Node):
262263
await self.send_to_node({

0 commit comments

Comments
 (0)