From 274529bb1a6eaccf0cd86efb168b05d58e33af60 Mon Sep 17 00:00:00 2001 From: emmatveev Date: Wed, 27 Nov 2024 04:19:05 +0300 Subject: [PATCH] fix --- daemons/poll.py | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/daemons/poll.py b/daemons/poll.py index c925ded..65415e9 100644 --- a/daemons/poll.py +++ b/daemons/poll.py @@ -23,16 +23,22 @@ class Daemon(base.Daemon): process = self.telegram_pollers[project_name][bot_name] if bot_info.get('poll_enabled'): if process is not None and process.is_alive: + print(f'process for {project_name} {bot_name} is alive') continue new_process = multiprocessing.Process(target=self.start_polling, args=[bot_info['secrets']['telegram_token'], bot_info['queue']]) + print(f'starting process for {project_name} {bot_name} is alive') new_process.start() self.telegram_pollers[project_name][bot_name] = new_process + print(f'started process for {project_name} {bot_name} is alive') else: - if process is None: + if process is None or not process.is_alive: + print(f'process for {project_name} {bot_name} is not alive') continue if process.is_alive: + print(f'terminating process for {project_name} {bot_name}') process.terminate() self.telegram_pollers[project_name][bot_name] = None + print(f'terminated process for {project_name} {bot_name}') time.sleep(10) def start_polling(self, telegram_token, queue):