pypushflow.AbstractActor.AbstractActor¶

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

Bases: ThreadCountingActor

connect(actor)[source]¶

getActorPath()[source]¶

hasFinished()[source]¶

hasStarted()[source]¶

property pool_resources¶

setFinished()[source]¶

setMongoAttribute(attribute, value)[source]¶

setStarted()[source]¶

trigger(inData)[source]¶

uploadInDataToMongo(actorData=None, script=None)[source]¶

uploadOutDataToMongo(actorData=None)[source]¶