pypushflow.PythonActor.PythonActor#

class pypushflow.PythonActor.PythonActor(parent=None, name='Python Actor', errorHandler=None, script=None, **kw)[source]#

Bases: AbstractActor

compileDownstreamData(result)[source]#
Parameters:

result (dict)

Return type:

dict

compileDownstreamErrorData(result)[source]#
Parameters:

result (dict)

Return type:

dict

connect(actor)#
connectOnError(actor)[source]#
errorHandler(exception)[source]#

Async callback in case of exception

Parameters:

exception (Exception)

getActorPath()#
hasFinished()#
hasStarted()#
property pool#
property pool_resources#
resultHandler(result)[source]#

Async callback in case of success

Parameters:

result (dict)

setFinished()#
setMongoAttribute(attribute, value)#
setStarted()#
trigger(inData)[source]#
Parameters:

inData (dict)

uploadInDataToMongo(actorData=None, script=None)#
uploadOutDataToMongo(actorData=None)#