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)¶