Hema Jayachandran
04/18/2024, 11:43 AMThe cached values aren't the same as the current call arguments
. What I am not able to figure out is why does it attempt to look for cached results when its completely a new launch plan. Any idea why would this happen ?Hema Jayachandran
04/18/2024, 11:43 AM# EXISTING LAUNCHPLAN
for ecosystem in parameters["ecosystems"]:
LaunchPlan.get_or_create(
name=f"launch_plan_{ecosystem.replace('-','_')}",
workflow=main_workflow,
schedule=CronSchedule(schedule=parameters["schedule"]),
fixed_inputs={
"ecosystem": ecosystem,
"lookback": parameters["lookback"],
},
max_parallelism=N_WORKERS,
)
# NEW LAUNCHPLAN
for ecosystem in parameters["ecosystems"]:
LaunchPlan.get_or_create(
name="launch_plan_wrapper",
workflow=wrapper_workflow,
fixed_inputs={"ecosystem": ecosystem, "backfill": 2},
)
David Espejo (he/him)
04/18/2024, 6:27 PMHema Jayachandran
04/18/2024, 8:10 PMlaunch_plan.py
. I was able to create multiple launch plans in one of our other application where the flytekit version is 1.8.1
. The above failing application has version 1.9.1 but I also tried with 1.11.0, still get the same error.Hema Jayachandran
04/18/2024, 8:57 PMDavid Espejo (he/him)
04/18/2024, 8:58 PM