Hi all, I am executing a flyte map_task, and the caching does not kick in when re-executing the workflow. My task looks as follows:

@task(cache=True, cache_version="1.0", requests=Resources(mem="12Gi", cpu="1"), retries=1)
def write_data(cfg: DictConfig, key: str) -> None:
   ....

and I am parallelizing over keys in my workflow as follows:

partial_task = partial(write_data, cfg=cfg)
map_task(partial_task, concurrency=30, min_success_ratio=0.8)(key=keys)

I am using flytekit version

1.10.0

you might have to explicitly set the metadata in the map_task

Hi @Jay Ganbat, thanks for the proposed solution. I attempted explicitly setting the metadata, but it did not work. I am getting

caching was disabled for this execution

in the flyte console:

@Ziyad Sheebaelhamd mind creating an issue here? [flyte-bug]

🐞 Create a new Flyte Bug issue: https://github.com/flyteorg/flyte/issues/new?assignees=&labels=bug%2Cuntriaged&template=bug_report.yaml&title=%5BBUG%5D+

btw, which version of flyte you are using?

pretty old version, posted above, 1.10

@Ziyad Sheebaelhamd do you see cache indicators for individual subtasks? In maptasks the top-level item as you've depicted in the UI will never show a cached indicator, rather each individual subtask has it's own indicators.