acoustic-carpenter-78188
12/11/2025, 5:02 PMmap_task are retried as specified in the task decorator retries=11 times.
@task(
retries=11,
)
def test(inp: int) -> None:
raise FlyteRecoverableException()
@workflow
def wf() -> None:
map_task(test)(inp=[i for i in range(3)])
Here, in the nodes array handler, for the example above nCtx.Node().GetRetryStrategy() is nil and therefore maxAttemptsValue := int(config.GetConfig().NodeConfig.DefaultMaxAttempts).
I would say this is not the desired behaviour
### Additional context to reproduce
No response
### Screenshots
No response
### Are you sure this issue hasn't been raised already?
• Yes
### Have you read the Code of Conduct?
• Yes
flyteorg/flyteacoustic-carpenter-78188
12/12/2025, 5:13 PM