flyteorg/flyte

[Core feature] Add timeout to ContainerTask

Open

#6 351 ouverte le 20 mars 2025

Voir sur GitHub
 (6 commentaires) (0 réactions) (1 assigné)Python (3 705 stars) (378 forks)batch import
enhancementgood first issuehelp wanted

Description

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

Guide contributeur

Stack technique
pythonkubernetes
Domaine
backend
Type d'issue
feature
DifficultéDifficulté estimée pour un nouveau contributeur, de 1 pour un très petit changement à 5 pour un travail expert.
3
Temps estiméFourchette de temps approximative pour investiguer, implémenter, tester et préparer une pull request.
1-2 days
Statut d'activitéDisponibilité apparente de l'issue : fraîche, active, ancienne, bloquée ou en attente d'un mainteneur.
blocked
ClartéClarté avec laquelle l'issue explique le changement attendu, les critères d'acceptation et la prochaine étape.
clear
Prérequis
PythonFlyte SDK basics
Accessibilité débutantScore de 1 à 100 estimant l'accessibilité de cette issue pour un premier contributeur.
40
Direction de recherche
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.