flow.schedule = get_schedule()

import datetime
from datetime import datetime, timedelta
from prefect.schedules import clocks, Schedule


def get_schedule():

    now = datetime.utcnow()

    clock1 = clocks.IntervalClock(
        interval=timedelta(minutes=10),
        parameter_defaults={
            "scope": "full",
        },
    )

    my_schedule = Schedule(
        clocks=[
            clock1,
        ]
    )

    return my_schedule

scheduled_hello.py

python scheduled_hello.py

from datetime import timedelta

from prefect import task, Flow
from prefect.schedules import IntervalSchedule


@task
def say_hello():
    print("Hello, world!")


schedule = IntervalSchedule(interval=timedelta(minutes=2))

with Flow("Scheduled Hello", schedule) as flow:
    say_hello()

flow.register(project_name='example',
              labels=['local'],
              idempotency_key=flow.serialized_hash())

flow.schedule = schedule

flow.register()

if os.environ["EXECUTOR"] == "aws" and os.environ["ENV"] == "prod":
        flow.schedule = get_schedule()

if

schedule = IntervalSchedule(interval=timedelta(minutes=2))

with Flow("Scheduled Hello") as flow:
    say_hello()

flow.schedule = schedule

flow.register(project_name='example',
              labels=['local'],
              idempotency_key=flow.serialized_hash())

$ pip show prefect
Name: prefect
Version: 0.15.0

sha256

image: prefecthq/apollo@sha256:65ca4f0a4a667fd48360a5c00b4670a796dbc43f2e3a1a0e40ad8b40e1e5cd7f
    ...
    image: prefecthq/server@sha256:0490b527756a53bd3c80513cf09d8c51fdf002c7991524898f62fdd43a31a343

schedule = IntervalSchedule(interval=timedelta(minutes=2))
with Flow("Scheduled Hello", schedule) as flow:
    say_hello()

schedule = IntervalSchedule(interval=timedelta(minutes=2))
with Flow("Scheduled Hello", schedule=schedule) as flow:
    say_hello()