pypushflow.ForkActor.ForkActor#

class pypushflow.ForkActor.ForkActor(parent=None, name='Fork actor', **kw)[source]#

Bases: AbstractActor

connect(actor)#
getActorPath()#
hasFinished()#
hasStarted()#
property pool_resources#
setFinished()#
setMongoAttribute(attribute, value)#
setStarted()#
trigger(inData)#
uploadInDataToMongo(actorData=None, script=None)#
uploadOutDataToMongo(actorData=None)#