Dennis Keck
07/27/2023, 4:39 PMfrom flytekit import workflow, task
@task(
cache=True,
cache_version="0"
)
def my_task() -> list[list[str]]:
return [["foo"], []]
@workflow
def my_workflow():
my_task()
Executing this a second time, the task will be stuck in Queued
and there is no error message shown to the user. The flytepropeller logs indicate that it interprets the type of the cached object wrongly:
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 > > > > ]
I assume this is is bug in flytepropeller and created an issue.Dan Rammer (hamersaw)
07/27/2023, 4:53 PMcache_version
? 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 Keck
07/27/2023, 4:59 PMDan Rammer (hamersaw)
07/27/2023, 5:00 PMDennis Keck
07/27/2023, 5:02 PM