I currently am with Flyte v1.11.0 and started to u...
# flyte-support
c
I currently am with Flyte v1.11.0 and started to use Intratask checkpoints. This works well when using normal tasks but fails when used inside mapped tasks. According to the docs (https://docs.flyte.org/en/v1.11.0/user_guide/advanced_composition/map_tasks.html) I would need to use ArrayNode in order to get support. So I imported the map_task from flytekit.experimental, but unfortunately, the same error
Checkpointing is not available, please check the version of the platform.
. Does v1.11.0 support checkpointing in mapped tasks?
d
Can you provide your 1. Python version 2. Flytekit version 3. Example code to reproduce this error?
c
Actually, flyte.binary (v1.11.0) pod is restarting due to an error
fatal error: concurrent map writes
so maybe the array node has some issues. (
/flyteorg/build/flytepropeller/pkg/controller/nodes/array/execution_context.go:29
). The python version is 3.11 and flytekit version is 1.11.0. I will try to create a minimal example and share.
d
Can you try the latest flute?
Flyte
I’ll help you ping someone who might know the answer after you try it
And also try the latest flytekit
Thank you
I’m not familiar with map task, but I can try my best to help you
c
That is a fair suggestion, unfortunately I have another issue with later flyte versions and the main reason I have not tried it. Will wait for that to be fixed (i.e. being able to define and run flyte within a jupyter notebook) and after that will try it. What I mainly want to know if map_array is something that I should even try to use in v1.11.0 for intra task checkpoints or if I should just wait until I upgrade.
d
Ok
Please provide example
And then I’ll ping maintianers