ewoksppf.bindings.InputMergeActor#

class ewoksppf.bindings.InputMergeActor(parent=None, name='Input merger', **kw)[source]#

Bases: AbstractActor

Requires triggers from some input actors before triggering the downstream actors. Optional triggers are cached or buffered (before first execution) and the last one is retained.

connect(actor)#
getActorPath()#
hasFinished()#
hasStarted()#
property pool_resources: int#
register_input_actor(actor)[source]#
Parameters:

actor (Optional[AbstractActor])

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(actorData=None, script=None)#
uploadOutDataToMongo(actorData=None)#