(self, task, *args, **kwargs)
| 1358 | |
| 1359 | |
| 1360 | def _exec_task(self, task, *args, **kwargs): |
| 1361 | if self.threaded: |
| 1362 | self.worker_pool.put(task, *args, **kwargs) |
| 1363 | else: |
| 1364 | try: |
| 1365 | task(*args, **kwargs) |
| 1366 | except Exception as e: |
| 1367 | handled = self._handle_exception(e) |
| 1368 | if not handled: |
| 1369 | raise e |
| 1370 | |
| 1371 | |
| 1372 | def stop_polling(self): |
no test coverage detected