Mehdi Nazari
08/03/2021, 4:41 PMKevin Kho
Mehdi Nazari
08/03/2021, 4:46 PMKevin Kho
Kevin Kho
now = Parameter("now", datetime.datetime.now())
then the datetime.datetime.now() will be evaluated during the build time and the date will be pinned during serialization. Instead you can do something like
now = Parameter("now", default="now")
and then use a task
@task
def get_now(time):
if time == "now":
return datetime.datetime.now()
Mehdi Nazari
08/03/2021, 4:58 PMMehdi Nazari
08/03/2021, 4:59 PMKevin Kho
context
inside your flow and pull out the relevant values.Mehdi Nazari
08/03/2021, 8:35 PMKevin Kho