Scheduling#

class flytekit.CronSchedule(cron_expression=None, schedule=None, offset=None, kickoff_time_input_arg=None)#

Use this when you have a launch plan that you want to run on a cron expression. This uses standard cron format in case where you are using default native scheduler using the schedule attribute.

CronSchedule(
    schedule="*/1 * * * *",  # Following schedule runs every min
)

See the User Guide for further examples.

Parameters:

  • cron_expression (str | None)

  • schedule (str | None)

  • offset (str | None)

  • kickoff_time_input_arg (str | None)

class flytekit.FixedRate(duration, kickoff_time_input_arg=None)#

Use this class to schedule a fixed-rate interval for a launch plan.

from datetime import timedelta

FixedRate(duration=timedelta(minutes=10))

See the fixed rate intervals chapter in the cookbook for additional usage examples.

Parameters:

  • duration (timedelta)

  • kickoff_time_input_arg (str | None)