new logger for manager

hivesolutions · Jul 22, 2015 · 2dc8598 · 2dc8598
1 parent 8e219bf
commit 2dc8598
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 2 deletions.
diff --git a/src/appier/async.py b/src/appier/async.py
@@ -41,6 +41,10 @@
 
 class AsyncManager(object):
 
+    def __init__(self, owner):
+        object.__init__(self)
+        self.owner = owner
+
     def start(self):
         pass
 
@@ -93,4 +97,6 @@ def handler(self):
             try: item = self.queue.pop(0)
             finally: self.condition.release()
             method, args, kwargs = item
-            method(*args, **kwargs)
+            try: method(*args, **kwargs)
+            except BaseException, exception:
+                self.owner.log_error(exception)
diff --git a/src/appier/base.py b/src/appier/base.py
@@ -259,7 +259,7 @@ def __init__(
         self.ssl = False
         self.local_url = None
         self.cache_d = self.cache_c()
-        self.manager = async.QueueManager()
+        self.manager = async.QueueManager(self)
         self.routes_v = None
         self.tid = None
         self.type = "default"