flyteorg/flyte

[Core feature] Add timeout to ContainerTask

Aperta

#6351 aperta il 20 mar 2025

Vedi su GitHubGuida contributor
 (6 commenti) (0 reazioni) (1 assegnatario)Python (378 fork)batch import
enhancementgood first issuehelp wanted

Metriche repository

Star
 (3705 stelle)
Metriche merge PR
 (Metriche PR in attesa)

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

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.
Tech stack
python
Dominio
backendapi
Tipo issue
Funzionalità
DifficoltàQuanto dovrebbe essere impegnativa per un nuovo contributor.
3
Tempo stimatoTempo stimato per completare e verificare uno scope piccolo.
1-2 giorni
Stato attivitàQuanto è probabile che la issue sia ancora attiva e reviewable.
Attiva
ChiarezzaQuanto chiaramente la issue descrive problema, scope e risultato atteso.
Chiara
Prerequisiti
PythonFlyte basics
Adatta ai principiantiQuanto la issue è adatta a contributor alla prima esperienza.
35