flyteorg/flyte

[Core feature] Add timeout to ContainerTask

Open

Aperta il 20 mar 2025

Vedi su GitHub
 (6 commenti) (0 reazioni) (1 assegnatario)Python (3705 star) (378 fork)batch import
enhancementgood first issuehelp wanted

Descrizione

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

Guida contributor

Tech stack
python
Dominio
backendapi
Tipo issue
feature
DifficoltàQuanto dovrebbe essere impegnativa per un nuovo contributor.
3
Tempo stimatoTempo stimato per completare e verificare uno scope piccolo.
1-2 days
Stato attivitàQuanto è probabile che la issue sia ancora attiva e reviewable.
active
ChiarezzaQuanto chiaramente la issue descrive problema, scope e risultato atteso.
clear
Prerequisiti
PythonFlyte basics
Adatta ai principiantiQuanto la issue è adatta a contributor alla prima esperienza.
35
Direzione di ricerca
Esamina come il timeout è implementato per le normali attività Python nel decoratore @task (probabilmente in flytekit/core/task.py). Quindi implementa un parametro timeout simile per ContainerTask in flytekit/core/container task.py. Assicurati che il timeout venga propagato alla specifica del Pod Kubernetes. Controlla i test esistenti per il comportamento del timeout e aggiungi i test corrispondenti.