apache/airflow

Mark a future task instance to success including downstream tasks using CLI

Open

#9327 aperta il 16 giu 2020

Vedi su GitHub
 (14 commenti) (0 reazioni) (0 assegnatari)Python (16.781 fork)batch import
area:CLIgood first issuekind:feature

Metriche repository

Star
 (44.809 star)
Metriche merge PR
 (Merge medio 7g 18h) (834 PR mergiate in 30 g)

Descrizione

Assume, there is a DAG with ID a_dag and five tasks with IDs dummy1, dummy2, dummy3, dummy4, dummy5. We want to mark the dummy3 task and all it's downstream tasks - dummy4,dummy5 etc to success from the next DAG run. Since it's a future task instance, we can't do that in the UI. So we can use make use of CLI.

If we want to mark a future task instance to success, we can use below command. airflow run -fAIim a_dag dummy3 2020-07-11T20:00:00+00:00

It would be great if we include downstream tasks in the above command, so that we do not have to run the above command for each downstream tasks separately.

Guida contributor

Direzione di ricerca
Esamina il codice CLI di Airflow per i comandi di stato delle attività (es. 'airflow tasks set state') e comprendi come vengono risolte le attività downstream. Guarda il parsing del DAG e i modelli delle istanze delle attività per estendere la funzionalità includendo le attività downstream.
Tech stack
python
Dominio
backendcli
Tipo issue
Funzionalità
DifficoltàQuanto dovrebbe essere impegnativa per un nuovo contributor.
3
Tempo stimatoTempo stimato per completare e verificare uno scope piccolo.
Mezza giornata
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
PythonAirflow basicsCLI usage
Adatta ai principiantiQuanto la issue è adatta a contributor alla prima esperienza.
60