pypushflow.AbstractActor.AbstractActor#

class pypushflow.AbstractActor.AbstractActor(parent=None, name=None, **kw)[source]#

Bases: ThreadCountingActor

connect(actor)[source]#
getActorPath()[source]#
property pool_resources: int#
setFinished()[source]#
setMongoAttribute(attribute, value)[source]#
setStarted()[source]#
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)[source]#
uploadOutDataToMongo(actorData=None)[source]#