Source code for pypushflow.tests.tasks.pythonActorAdd

import time



[docs]
def run(value=None, **kwargs):
    time.sleep(1)
    if value is None:
        raise RuntimeError("Missing argument 'value'!")
    value = value + 1
    return {"value": value}