Hello 👋 As part of our current migration, we have set up a launch plan which is scheduled to run daily at 7. The workflow expects an
input_date
as one of the parameter. This launch plan was updated in the cluster yesterday (2023-07-12).
While we were expecting todays execution to pick the input date as 2023-07-13 we noticed that it picked 2023-07-12 instead (This is our first scheduled run). Is our assumption right that its because of this
default_inputs={"date": datetime.today().strftime("%Y-%m-%d")}
that it is set only once while the launch plan is updated or created and hence picking that date?
LaunchPlan.get_or_create(
name=f"launch_plan_{ecosystem}",
workflow=test_workflow,
schedule=CronSchedule(schedule="0 7 * * *"),
default_inputs={"date": datetime.today().strftime("%Y-%m-%d")},
fixed_inputs={"ecosystem": ecosystem},
)
Is there a better way to handle input dates ? All our pipelines expects an input date as parameter; for some it’s the same date as execution date and for some it’s one day behind the execution date.