dazzling-apple-56709
07/18/2025, 6:00 AMprocess_newsletter_mapped = map_task(
process_newsletter_task,
concurrency=3,
)
@workflow(
failure_policy=WorkflowFailurePolicy.FAIL_AFTER_EXECUTABLE_NODES_COMPLETE,
)
def process_newsletter():
usernames = collect_users()
process_newsletter_mapped(username=usernames)
cron_lp = flytekit.LaunchPlan.get_or_create(
workflow=process_newsletter,
name="every_10_minutes",
schedule=CronSchedule(
schedule="*/10 * * * *", # Every 10 minutes
kickoff_time_input_arg=None
)
)
I have activated the launchplan and execute it manually and it worked, but as you can see, the manual execution was successful 17 minutes ago and the schedule is setup every 10 minutes. Something is wrong heredazzling-apple-56709
07/18/2025, 6:02 AMNAME READY STATUS RESTARTS AGE
datacatalog-5fdb8f6c46-2sq8n 1/1 Running 0 3d12h
flyte-pod-webhook-9bc44b46-6sglm 1/1 Running 0 3d12h
flyteadmin-846fdb797-p2s7l 1/1 Running 0 3d12h
flyteconsole-5f8886885d-b9cvp 1/1 Running 0 3d12h
flytepropeller-567fc9c857-q6c4p 1/1 Running 0 3d12h
postgres-6f57bb9889-sh6zg 1/1 Running 0 3d12h
syncresources-5d446b76cd-8ddg5 1/1 Running 0 3d12h
tall-appointment-97015
07/18/2025, 6:40 AMworkflow_scheduler
option is disabled by default. If you installed with helm, check your flyte-core
configuration. You should see a flytescheduler pod running once the scheduler is enabled.cold-horse-70195
07/18/2025, 6:06 PMdazzling-apple-56709
07/18/2025, 7:13 PM