From 14368e5a7bdcc4b6d3b151ecd9cb3162c30f292e Mon Sep 17 00:00:00 2001 From: 简律纯 Date: Thu, 18 Jul 2024 23:21:38 +0800 Subject: refactor: Comment hook function while running the rules packages TODO: builtin hook function in every rules packages. --- hrc/core.py | 41 ++++++++++++++++++++++------------------- 1 file changed, 22 insertions(+), 19 deletions(-) (limited to 'hrc/core.py') diff --git a/hrc/core.py b/hrc/core.py index 3d19b46..35f613d 100644 --- a/hrc/core.py +++ b/hrc/core.py @@ -158,31 +158,34 @@ class Core: await core_run_hook_func(self) try: - for _rule in self.rules: - for rule_enable_hook_func in self._rule_enable_hooks: - await rule_enable_hook_func(_rule) - try: - await _rule.enable() - except Exception as e: - self.error_or_exception( - f"Enable rule {_rule!r} failed:", e) - - for _rule in self.rules: - for rule_run_hook_func in self._rule_run_hooks: - await rule_run_hook_func(_rule) - _rule_task = asyncio.create_task(_rule.safe_run()) - self._rule_tasks.add(_rule_task) - _rule_task.add_done_callback(self._rule_tasks.discard) + ########################################################## + # @TODO: builtin hook function in every rules packages. + ########################################################## + # for _rule in self.rules: + # for rule_enable_hook_func in self._rule_enable_hooks: + # await rule_enable_hook_func(_rule) + # try: + # await _rule.enable() + # except Exception as e: + # self.error_or_exception( + # f"Enable rule {_rule!r} failed:", e) + + # for _rule in self.rules: + # for rule_run_hook_func in self._rule_run_hooks: + # await rule_run_hook_func(_rule) + # _rule_task = asyncio.create_task(_rule.safe_run()) + # self._rule_tasks.add(_rule_task) + # _rule_task.add_done_callback(self._rule_tasks.discard) await self.should_exit.wait() if hot_reload_task is not None: # pragma: no cover await hot_reload_task finally: - for _rule in self.rules: - for rule_disable_hook_func in self._rule_disable_hooks: - await rule_disable_hook_func(_rule) - await _rule.disable() + # for _rule in self.rules: + # for rule_disable_hook_func in self._rule_disable_hooks: + # await rule_disable_hook_func(_rule) + # await _rule.disable() while self._rule_tasks: await asyncio.sleep(0) -- cgit v1.2.3-70-g09d2