https://flyte.org logo
#ask-the-community
Title
# ask-the-community
f

Fabio Grätz

03/13/2024, 11:01 AM
The release notes of 1.11 say that caching is now overrible on workflow nodes which is an amazing feature 🙂 Has anyone made this work? When trying the new release, for me it appears not to work yet:
Copy code
@task(
    cache_version="1.0",
    cache=True,
)
def foo() -> str:
    return "foo"


@workflow
def my_wf():
    foo()
    foo().with_overrides(
        cache_version="314134",
    )
Assuming there is a cache entry for version 1.0, I would expect that the second node in the graph gets re-executed but for me it doesn’t, flytekit and helm chart on 1.11: I saw implementation in flytekit and flyteidl. Is implementation in propeller missing or am I doing something wrong? :)
k

Ketan (kumare3)

03/13/2024, 2:28 PM
I don’t think this was implemented in the back
e

Eduardo Apolinario (eapolinario)

03/27/2024, 10:11 PM
@Fabio Grätz, you're correct, there's work afoot to get this working for workflows. As for how this is supported in tasks, https://github.com/flyteorg/flyte/issues/2734#issuecomment-1874369569 has more context.
k

Ketan (kumare3)

03/28/2024, 2:56 AM
I don’t know if the launchplan caching support will be in oss as folks can shoot themeselves I the foot
f

Fabio Grätz

03/28/2024, 7:27 AM
Thanks for the replies! Do I understand it correctly that moving the cache lookup from the task to the node is a pre-requisite for allowing cache overrides as overrides always happen on the node?
3 Views