bright-florist-6681
03/03/2023, 10:54 PMcool-lifeguard-49380
03/04/2023, 10:40 AM@workflow
def date_formatter_wf(kickoff_time: datetime):
formatted_kickoff_time = format_date(run_date=kickoff_time)
print(formatted_kickoff_time)
cron_lp = LaunchPlan.get_or_create(
name="my_cron_scheduled_lp",
workflow=date_formatter_wf,
schedule=CronSchedule(
# Note that the ``kickoff_time_input_arg`` matches the workflow input we defined above: kickoff_time
# But in case you are using the AWS scheme of schedules and not using the native scheduler then switch over the schedule parameter with cron_expression
schedule="*/1 * * * *", # Following schedule runs every min
kickoff_time_input_arg="kickoff_time",
),
)
freezing-airport-6809
pyflyte backfill
https://docs.flyte.org/projects/flytekit/en/latest/pyflyte.html#pyflyte-backfillbright-florist-6681
03/05/2023, 4:10 AM