Task Retry

Automatically retry a task when it fails. Set retry on the @action decorator to define how many times the task should be retried before giving up.

Retry

Python 3.8+

from dotflow import DotFlow, action


@action(retry=5)
def simple_step():
    raise Exception("Unknown")


@action
class SimpleStepX:
    @action(retry=5)
    def run(self):
        raise Exception("Unknown")


@action(retry=3)
class SimpleStepY:
    @action
    def run(self):
        raise Exception("Unknown")


def main():
    workflow = DotFlow()

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

    workflow.task.add(step=SimpleStepX)
    workflow.start()
    workflow.task.clear()

    workflow.task.add(step=SimpleStepY)
    workflow.start()
    workflow.task.clear()

    return workflow


if __name__ == "__main__":
    main()

Retry with Delay

Add retry_delay to wait a fixed number of seconds between each attempt.

Python 3.8+

from dotflow import DotFlow, action


@action(retry=3, retry_delay=5)
def simple_step():
    raise Exception("Unknown")


@action
class SimpleStepX:
    @action(retry=3, retry_delay=5)
    def run(self):
        raise Exception("Unknown")


@action(retry=3, retry_delay=5)
class SimpleStepY:
    @action
    def run(self):
        raise Exception("Unknown")


def main():
    workflow = DotFlow()

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

    workflow.task.add(step=SimpleStepX)
    workflow.start()
    workflow.task.clear()

    workflow.task.add(step=SimpleStepY)
    workflow.start()
    workflow.task.clear()

    return workflow


if __name__ == "__main__":
    main()

References

• Action
• Error Handling