mirror/pyTelegramBotAPI
1
0
Fork 0
mirror of https://github.com/eternnoir/pyTelegramBotAPI.git synced 2023-08-10 21:12:57 +03:00
Code Releases Activity

WorkerThreads now log ApiExceptions

Browse Source
This commit is contained in:
Pieter van den Ham 2015-10-01 11:33:23 +02:00
parent 941b8ac5d0
commit 60ca1751ca
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
telebot/util.py
View File

@ -9,6 +9,9 @@ try:
except ImportError: except ImportError:
import queue as Queue import queue as Queue
from apihelper import ApiException
from telebot import logger
class ThreadPool: class ThreadPool:
class WorkerThread(threading.Thread): class WorkerThread(threading.Thread):
@ -30,6 +33,8 @@ class ThreadPool:
task(*args, **kwargs) task(*args, **kwargs)
except Queue.Empty: except Queue.Empty:
pass pass
except ApiException as e:
logger.exception(e)
def stop(self): def stop(self):
self._running = False self._running = False
@ -49,6 +54,7 @@ class ThreadPool:
for worker in self.workers: for worker in self.workers:
worker.join() worker.join()
class AsyncTask: class AsyncTask:
def __init__(self, target, *args, **kwargs): def __init__(self, target, *args, **kwargs):
self.target = target self.target = target