Simple question but if I am running a

map_task

with

min_success_ratio=1.0

and I want to retry the entire

map_task

call on a failure, is specifying

retries=5

in the task definition of the function that calls

map_task

enough?

not sure the current state, but we needed to add

TaskMetaData

to specify the retry behaviors

metadata=TaskMetadata(
        cache=True,       cache_version=get_internal_cache_version(),
        interruptible=True,
        retries=DEFAULT_DYNAMIC_TASK_RETRY,
    )