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?@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
05/27/2020, 12:51 PMAvi 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 😞cache_for
nicholas
05/27/2020, 1:10 PMAvi A
05/27/2020, 1:11 PMnicholas
05/27/2020, 1:22 PMAvi A
05/27/2020, 1:24 PMnicholas
05/27/2020, 1:31 PM