async workers

alttch · Jul 14, 2019 · 09dfa22 · 09dfa22
1 parent 98a3a35
commit 09dfa22
Show file tree

Hide file tree

Showing 9 changed files with 271 additions and 130 deletions.
diff --git a/TODO.todo b/TODO.todo
@@ -1,2 +0,0 @@
-- [ ] start interval worker executor manually (keep interval)
-- [ ] async executors

diff --git a/atasker/__init__.py b/atasker/__init__.py
@@ -1,7 +1,7 @@
 __author__ = "Altertech Group, http://www.altertech.com/"
 __copyright__ = "Copyright (C) 2018-2019 Altertech Group"
 __license__ = "Apache License 2.0"
-__version__ = "0.1.1"
+__version__ = "0.1.2"
 
 from atasker.supervisor import TaskSupervisor
 from atasker.supervisor import TASK_LOW

diff --git a/atasker/f.py b/atasker/f.py
@@ -1,7 +1,7 @@
 __author__ = "Altertech Group, http://www.altertech.com/"
 __copyright__ = "Copyright (C) 2018-2019 Altertech Group"
 __license__ = "Apache License 2.0"
-__version__ = "0.1.1"
+__version__ = "0.1.2"
 
 import traceback
 import threading

diff --git a/atasker/supervisor.py b/atasker/supervisor.py
@@ -1,7 +1,7 @@
 __author__ = "Altertech Group, http://www.altertech.com/"
 __copyright__ = "Copyright (C) 2018-2019 Altertech Group"
 __license__ = "Apache License 2.0"
-__version__ = "0.1.1"
+__version__ = "0.1.2"
 
 import threading
 import time
@@ -182,6 +182,9 @@ async def _main_loop(self):
             if r == RQ_SCHEDULER:
                 logger.debug('Supervisor: new scheduler {}'.format(res))
                 scheduler_task = self.event_loop.create_task(res.loop())
+                if hasattr(res, 'extra_loops'):
+                    for l in res.extra_loops:
+                        self.event_loop.create_task(getattr(res, l)())
                 with self._lock:
                     self._schedulers[res] = (res, scheduler_task)
             elif r == RQ_TASK:

diff --git a/atasker/threads.py b/atasker/threads.py
@@ -1,7 +1,7 @@
 __author__ = "Altertech Group, http://www.altertech.com/"
 __copyright__ = "Copyright (C) 2018-2019 Altertech Group"
 __license__ = "Apache License 2.0"
-__version__ = "0.1.1"
+__version__ = "0.1.2"
 
 import threading
 import time