acoustic-carpenter-78188
07/18/2023, 10:36 PM[1/1] currentAttempt done. Last Error: USER::task execution timeout [10s] expired
An mre/snippet:
import time
from flytekit import task, workflow, map_task
@task(timeout=10)
def unpredictable_task(t: int):
time.sleep(t)
@workflow
def unpredictable_workflow():
result = map_task(unpredictable_task, min_success_ratio=0.0)(t=[1,2,3,11,12,13])
Expected behavior
I would expect map_task to succeed and for the result to be of length 3 corresponding to the successful tasks.
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/flyte