flyteorg/flyte

[Core feature] Add timeout to ContainerTask

Open

#6.351 geöffnet am 20. März 2025

Auf GitHub ansehen
 (6 Kommentare) (0 Reaktionen) (1 zugewiesene Person)Python (3.705 Stars) (378 Forks)batch import
enhancementgood first issuehelp wanted

Beschreibung

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

Contributor Guide

Tech Stack
pythonkubernetes
Domain
backend
Issue Type
feature
SchwierigkeitGeschätzte Implementierungsschwierigkeit für neue Contributors, von 1 für sehr kleine Änderungen bis 5 für Expertenarbeit.
3
Geschätzte ZeitEin grober Zeitrahmen, um zu recherchieren, zu implementieren, zu testen und einen Pull Request vorzubereiten.
1-2 days
AktivitätsstatusWie verfügbar das Issue gerade wirkt: frisch, aktiv, stale, blockiert oder wartet auf Maintainer-Input.
blocked
KlarheitWie klar das Issue die erwartete Änderung, Akzeptanzkriterien und den nächsten Schritt erklärt.
clear
Voraussetzungen
PythonFlyte SDK basics
EinsteigerfreundlichkeitEin Score von 1 bis 100, der schätzt, wie zugänglich dieses Issue für First-Time Contributors ist.
40
Research-Richtung
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.