flyteorg/flyte

[Core feature] Add timeout to ContainerTask

Open

#6,351 创建于 2025年3月20日

在 GitHub 查看
 (6 评论) (0 反应) (1 负责人)Python (3,705 star) (378 fork)batch import
enhancementgood first issuehelp wanted

描述

Motivation: Why do you think this is important?

For regular python tasks the user can set a timeout by passing timeout in the @task decorator. I think the same should be possible for ContainerTasks.

Goal: What should the final outcome look like, ideally?

e.g. ContainerTask(..., timeout=timedelta(seconds=60) should set a 60 second timeout

Describe alternatives you've considered

I think it could be done via PodTemplates atm but that seems overkill for something like this.

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

贡献者指南

技术栈
pythonkubernetes
领域
backend
议题类型
feature
难度面向新贡献者的预计实现难度，1 表示很小改动，5 表示专家级工作。
3
预计时间有经验贡献者完成调查、实现、测试并准备 pull request 的粗略时间范围。
1-2 days
活动状态议题当前的可参与程度：新鲜、活跃、陈旧、阻塞或等待维护者输入。
blocked
清晰度议题是否清楚说明期望改动、验收标准和下一步。
clear
前置要求
PythonFlyte SDK basics
新手友好度1-100 的估计分数，表示该议题对首次贡献者的友好程度。
40
研究方向
Examine how timeout is implemented for regular Python tasks in the @task decorator (likely in flytekit/core/task.py). Then implement a similar timeout parameter for ContainerTask in flytekit/core/container task.py. Ensure the timeout is propagated to the Kubernetes Pod spec. Check existing tests for timeout behavior and add corresponding tests.