Klaus Stadler
02/03/2021, 2:14 PMdaniel
02/03/2021, 2:28 PMKlaus Stadler
02/03/2021, 2:34 PMdaniel
02/03/2021, 3:06 PMKlaus Stadler
02/03/2021, 4:06 PMdaniel
02/03/2021, 4:47 PMdhume
03/22/2021, 3:10 PMdemo_schedule = ScheduleDefinition(
name="DemoSchedule",
cron_schedule="*/2 * * * *",
pipeline_name="demo_pipeline",
run_config={
"solids": {
"second_power": {
"inputs": {
"date": {
"value": datetime.datetime.now().strftime(
"%m/%d/%Y, %H:%M:%S"
)
},
}
},
},
},
mode="dev",
)
And it wasn’t quite working as I expected. It was just setting the date at the time of the daemon started up but wasn’t dynamically being set at the time the schedule was run.
I’m sure I’m doing something wrongdaniel
03/22/2021, 3:14 PMrun_config_fn
with a lambda, not run_config - that'll make it computed at execution time rather than at definition loading timedhume
03/22/2021, 3:15 PMrun_config
OR run_config_fn