def notify()

in src/dubbo/cluster/directories.py [0:0]

• 12 lines of code
• 4 McCabe index (conditional complexity)

    def notify(self, urls: list[URL]) -> None:
        old_invokers = self._invokers
        self._invokers = {}

        # create new invokers
        for url in urls:
            k = str(url)
            if k in old_invokers:
                self._invokers[k] = old_invokers[k]
                del old_invokers[k]
            else:
                self._invokers[k] = self._protocol.refer(url)

        # destroy old invokers
        for invoker in old_invokers.values():
            invoker.destroy()