ewoksppf.bindings.EwoksPythonActor#

class ewoksppf.bindings.EwoksPythonActor(node_id, node_attrs, **kw)[source]#

Bases: PythonActor

compileDownstreamData(result)[source]#

Parameters:: result (dict)
Return type:: dict

compileDownstreamErrorData(result)#

Parameters:: result (dict)
Return type:: dict

connect(actor)#

connectOnError(actor)#

errorHandler(exception)#

Async callback in case of exception

Parameters:: exception (Exception)

getActorPath()#

hasFinished()#

hasStarted()#

property pool#

property pool_resources#

resultHandler(result)#

Async callback in case of success

Parameters:: result (dict)

setFinished()#

setMongoAttribute(attribute, value)#

setStarted()#

trigger(inData, **kwargs)#

This method

starts a scheduler thread (increments the thread counter),
calls ActorInterface._execute (actor-specific logic + triggering downstream actors),
ends the scheduler thread (decrements the thread counter).

When ActorInterface._execute is asynchronous, the scheduler thread needs to be deferred and executed as a callback once the asynchronous job completes.

Parameters:: inData (dict)

uploadInDataToMongo(**kw)[source]#

uploadOutDataToMongo(**kw)[source]#