<#5543 [Core feature] Add support cache for dynami...
# flytekit
a
#5543 [Core feature] Add support cache for dynamic spec Issue created by pingsutw ### Motivation: Why do you think this is important? Flyte launches a new pod to compile the dynamic task again, even if the input is the same. @dynamic(container_image=image_spec, cache_version="1", cache=True) def embedding_generation(shards: List[List[Annotated[np.ndarray, kwtypes(allow_pickle=True)]]]) -> List[List[FlyteDirectory]]: vectorstores = [] for shard in shards: vectorstores.append(map_task(create_embeddings)(chunks=shard)) return vectorstores Use cases: 1. Run dynamic workflow 2.
create_embeddings
OOMs 3. Increase resource for
create_embeddings
4. Rerunning a dynamic task: I expected Propeller to read the dynamicSpec (future.pb) from the cache instead of launching a pod and recompiling the workflow ### Goal: What should the final outcome look like, ideally? The propeller should return a dynamic spec from the cache if the input hasn't been changed. ### Describe alternatives you've considered NA ### Propose: Link/Inline OR Additional context No response ### Are you sure this issue hasn't been raised already? • Yes ### Have you read the Code of Conduct? • Yes flyteorg/flyte