fancy-yak-23698
11/02/2022, 10:09 PM@workflow
def cohort_ltv_inference(inference_date: datetime, n_days_horizon: int) -> bool:
...
I had created a schedule in my launch plan but failed to provide kickoff_time_input_arg
or default_inputs
.
launch_plan = LaunchPlan.get_or_create(
name="pir_cohort_ltv_inference",
workflow=cohort_ltv_inference,
schedule=CronSchedule(
schedule="45 17 * * *", # At 17:45 daily.
),
)
In the workflow web ui, I see the schedule displayed:
Schedules
At 05:45 PM
But when I noticed that no scheduled run was actually happening, I looked through the scheduler logs and saw messages like this:
rpc error: code = InvalidArgument desc = expected_inputs inference_date missing
Ideally the end user would be alerted about this earlier.
I saw a related issue on github here, and a PR here. I haven't worked in Go, but I think the function validateLaunchSpec
doesn't handle the case of no default_inputs
and no fixed_inputs
passed to the launch plan get_or_create
.
In general I'm missing some of the familiar scheduler UI I am used to from my experience with Airflow. I know these are very different projects, but for almost all my use cases, I'll eventually be running the ML pipeline on a schedule.fancy-yak-23698
11/02/2022, 10:11 PM2022-11-01T17:45:25-07:00
. So it seems like it is interpreting "17:45" as "America/Pacific" rather than "UTC".tall-lock-23197
icy-agent-73298
11/03/2022, 7:20 AMicy-agent-73298
11/03/2022, 9:26 AMfancy-yak-23698
11/04/2022, 5:48 PM