step_function_result_storage.py

#!/usr/bin/env python

from dotflow import DotFlow, action


@action
def simple_step():
    return "ok"


def main():
    workflow = DotFlow()

    workflow.task.add(step=simple_step)
    workflow.start()

    for storage in workflow.result_storage():
        print(storage)
        assert storage == "ok"

    return workflow


if __name__ == "__main__":
    main()