Avi A
05/27/2020, 12:35 PMResult we longed for: I see that the default is to cache the results per task, and it’s possible to cache per day/today/tomorrow when using the target formatting. Is there a behavior similar to cache_validator , allowing us to cache the results per set of attributes?Avi A
05/27/2020, 12:40 PM@task
def A(p: int):
return some_object
@task
def B(p: int):
return some_object
with Flow() as flow:
p = Parameter('p')
a = A(p)
b = B(a)
can I cache the result of B based on the value of the input parameter p (not a), without specifically mentioning it in task B? meaning having it read from the upsteam?nicholas
Avi A
05/27/2020, 12:53 PMtarget, it seems as if the task is not cached at all. I mean, it is cached, but since the exact timestamp when the task was run (not even including its name), then this cache is practically never read 😞Avi A
05/27/2020, 12:53 PMcache_fornicholas
Avi A
05/27/2020, 1:11 PMAvi A
05/27/2020, 1:11 PMnicholas
Avi A
05/27/2020, 1:24 PMAvi A
05/27/2020, 1:24 PMAvi A
05/27/2020, 1:25 PMnicholas