Dennis Keck07/27/2023, 4:39 PM
Executing this a second time, the task will be stuck in
from flytekit import workflow, task @task( cache=True, cache_version="0" ) def my_task() -> list[list[str]]: return [["foo"], ] @workflow def my_workflow(): my_task()
and there is no error message shown to the user. The flytepropeller logs indicate that it interprets the type of the cached object wrongly:
I assume this is is bug in flytepropeller and created an issue.
Error when trying to reconcile workflow. Error [Failed to check Catalog for previous results: unexpected artifactData: [o0] type: [collection_type:<union_type:<variants:<collection_type:<simple:NONE > > variants:<collection_type:<simple:STRING > > > > ]
Dan Rammer (hamersaw)07/27/2023, 4:53 PM
? i know the input interface is included in the cache key, but i'm not sure if the outputs are. this error seems to say "we're expected type N because that is what is stored in the cache, but the task output is actually type M"
Dennis Keck07/27/2023, 4:59 PM
Dan Rammer (hamersaw)07/27/2023, 5:00 PM
Dennis Keck07/27/2023, 5:02 PM