Sleep

Example: sleep.py.

Run it

python examples/sleep.py

from __future__ import annotations

from datetime import timedelta

from flux import ExecutionContext
from flux.workflow import workflow
from flux.tasks import sleep


@workflow
async def sleep_workflow(ctx: ExecutionContext):
    await sleep(timedelta(seconds=2))
    await sleep(timedelta(seconds=5))
    await sleep(3.5)


if __name__ == "__main__":  # pragma: no cover
    ctx = sleep_workflow.run()
    print(ctx.to_json())

Last verified against Flux 0.56.0.