Bring your towel and join one of the fastest growing data communities. Welcome to our second-generation open source orchestration platform, a completely rethought approach to dataflow automation.

Prefect Community

Hi together,
Is there a way to schedule a flow to start as soon as the previous run of the same flow finished?

Hi. You can have multiple scheduled/ongoing runs for a flow at the same time. Probably you'd want to give them different values for their parameters, though.

<@U02TM1HHJDR> indirectly but there is! Check out this Discourse topic <https://discourse.prefect.io/t/how-to-accomplish-a-never-ending-flow-or-skip-a-new-scheduled-run-if-the-previous-flow-run-hasnt-finished-yet/334|https://discourse.prefect.io/t/how-to-accomplish-a-never-ending-flow-or-skip-a-new-scheduled-run-if-the-previous-flow-run-hasnt-finished-yet/334>

Thank's <@U02H1A95XDW>. I think this is what I was looking for :slightly_smiling_face:

Is it also possible to combine the logic of never ending flows with a scheduler? In other words: If the flow is successfully completed, start it again directly, but only between 05:00am - 08:00pm?

Sure it's possible, as easy as `.py` :slightly_smiling_face:
```import prefect
from prefect import task, Flow
from prefect.tasks.prefect import create_flow_run
import time
import pendulum


@task(log_stdout=True)
def hello_world():
    print("Sleeping...")
    time.sleep(4)  # to have enough time to kill it
    return "hello world"


def never_ending_state_handler(obj, old_state, new_state):
    if new_state.is_successful():
        logger = prefect.context.get("logger")
        now = pendulum.now().time()  # change to utcnow if you prefer UTC time
        if pendulum.time(5) &lt;= now &lt;= pendulum.time(20):
            <http://logger.info|logger.info>("It's between 5 AM and 8 PM - creating a new run...")
            create_flow_run.run(flow_name="never-ending-flow", project_name="community")
        else:
            <http://logger.info|logger.info>("It's NOT between 5 AM and 8 PM - ending flow runs for today")
    return new_state


with Flow("never-ending-flow", state_handlers=[never_ending_state_handler]) as flow:
    hello_task = hello_world()```

This line does the "scheduling" part:
```if pendulum.time(5) &lt;= now &lt;= pendulum.time(20):```

Very nice, thanks again! I was thinking of a similar solution in Python, but I was afraid that there would already be a BP from you that is not realised in Python.