Commit eca70f78 authored by Wout De Nolf's avatar Wout De Nolf
Browse files

Merge branch 'apply_async_error_handler_bug' into 'main'

apply_async error handler only receives one argument

See merge request !13
parents b382c6cd f85db8fc
Pipeline #54694 passed with stage
in 28 seconds
...@@ -170,8 +170,12 @@ class PythonActor(AbstractActor): ...@@ -170,8 +170,12 @@ class PythonActor(AbstractActor):
time.sleep(1) time.sleep(1)
self.errorHandler(inData, e) self.errorHandler(inData, e)
else: else:
def errorHandler(e):
self.errorHandler(inData, e)
with self._postpone_end_thread( with self._postpone_end_thread(
self.triggerDownStreamActor, self.errorHandler self.triggerDownStreamActor, errorHandler
) as (callback, errorCallback): ) as (callback, errorCallback):
actorWrapper = ActorWrapper(, actorWrapper = ActorWrapper(, = AsyncFactory( = AsyncFactory(
Supports Markdown
0% or .
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment