apply_async error handler only receives one argument

pypushflow/PythonActor.py

@@ -170,8 +170,12 @@ class PythonActor(AbstractActor):
             time.sleep(1)
             self.errorHandler(inData, e)
         else:
+
+            def errorHandler(e):
+                self.errorHandler(inData, e)
+
             with self._postpone_end_thread(
-                self.triggerDownStreamActor, self.errorHandler
+                self.triggerDownStreamActor, errorHandler
             ) as (callback, errorCallback):
                 actorWrapper = ActorWrapper(self.name, module.run)
                 self.af = AsyncFactory(