GitLab will be upgraded on June 23rd evening. During the upgrade the service will be unavailable, sorry for the inconvenience.

Commit f0c27739 authored by Operator for ID30's avatar Operator for ID30

Fixed problem with callback for actors with no downstream connection

parent 00f0bb9e
......@@ -163,21 +163,11 @@ class PythonActor(AbstractActor):
}
oldInData['WorkflowException'] = exceptionDict
self.triggerOnError(oldInData)
elif len(self.listDownStreamActor) == 0:
self.af = AsyncFactory(self.actorWrapper.run)
self.af.call(inData)
# elif self.errorHandler is None:
# self.af = AsyncFactory(self.actorWrapper.run,
# callback=self.triggerDownStreamActor,
# errorCallback=self.errorHandler
# )
# self.af.call(inData)
else:
self.af = AsyncFactory(self.actorWrapper.run,
callback=self.triggerDownStreamActor,
errorCallback=self.errorHandler)
self.af.call(inData)
self.af = AsyncFactory(self.actorWrapper.run,
callback=self.triggerDownStreamActor,
errorCallback=self.errorHandler)
self.af.call(inData)
def errorHandler(self, exception):
logger.error('Error when running actor {0}!'.format(self.name))
workflowException = WorkflowException(
......
Markdown is supported
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