Comment faire pour arrêter et tuer la circulation de l'Air des tâches à partir de l'INTERFACE utilisateur
Comment puis-je arrêter ou tuer une tâche en cours d'exécution sur l'écoulement de l'INTERFACE utilisateur? Je suis à l'aide de LocalExecutor.
Même si j'utilise CeleryExecutor, comment puis-je tuer/arrêt de la tâche en cours d'exécution?
Sur " Tâches Récentes de presse de l'exécution de l'icône et de la circulation de l'Air est automatiquement, exécutez la requête de recherche avec les filtres pour le groupe Id et de l'État égale à 'courir' et afficher les résultats sur la Tâche des Instances de l'écran (vous pouvez le trouver manuellement sur l'onglet Parcourir > la Tâche des Instances).
Vous pouvez y sélectionner les tâches présentées et les mettre dans un autre état ou les supprimer.
Veuillez noter que si le groupe est actuellement en cours d'exécution, le flux d'Air planificateur va commencer à nouveau les tâches que vous supprimez. Donc, soit vous vous arrêtez le groupe d'abord par l'évolution de son état ou d'arrêter le planificateur (si vous êtes en cours d'exécution sur un environnement de test).
Elle n'redémarrer la tâche, même si j'arrête le planificateur et de supprimer la tâche? Si vous arrêtez le planificateur et vous ne voulez pas que la tâche à exécuter de nouveau, il suffit de définir la tâche manuellement à l'état de "succès" au lieu de la supprimer. Si vous venez de le supprimer, le planificateur va exécuter cette tâche à nouveau. J'ai mis en pause le DAG et supprimé les dossiers, mais les processus sont toujours en cours d'exécution. Est-il un moyen de changer l'état conformément à l'interprète, mais aussi de tuer le processus sous-jacent?
Pas normalement, non. Vous pouvez arrêter un dag (décochez la case en cours d'exécution) et d'effacer les tâches états ou même de les supprimer dans l'INTERFACE utilisateur. Le réel de l'exécution des tâches à l'exécuteur de ne pas arrêter, mais peut-être tué si l'exécuteur testamentaire se rend compte que ce n'est pas dans la base de données de plus.
Comme menioned par Pablo et Jorge pause de la Dag ne va pas arrêter la tâche d'être exécuté si l'exécution a déjà commencé. Il y a cependant un moyen d'arrêter une tâche en cours d'exécution à partir de l'INTERFACE utilisateur, mais c'est un peu hacky.
Lorsque la tâche est sur running état, vous pouvez cliquer sur CLEAR cela appel job.kill() la tâche sera définie à shut_down et a déménagé à up_for_retry immédiatement d'où il est arrêté.
Clairement la circulation de l'Air n'a pas pour but de vous à des tâches claires dans Running état toutefois, puisque la circulation de l'Air n'a pas le désactiver, soit vous pouvez l'utiliser comme je l'ai suggéré. La circulation de l'air signifiait CLEAR pour être utilisé avec failed, up_for_retry etc... Peut-être dans l'avenir, la collectivité utilise ce bug(?) et de mettre en œuvre la présente comme une fonctionnalité à "arrêter la tâche".
Dans les DAGs écran, vous pouvez voir les tâches en cours d'exécution:
Exemple
Sur " Tâches Récentes de presse de l'exécution de l'icône et de la circulation de l'Air est automatiquement, exécutez la requête de recherche avec les filtres pour le groupe Id et de l'État égale à 'courir' et afficher les résultats sur la Tâche des Instances de l'écran (vous pouvez le trouver manuellement sur l'onglet Parcourir > la Tâche des Instances).
Vous pouvez y sélectionner les tâches présentées et les mettre dans un autre état ou les supprimer.
Veuillez noter que si le groupe est actuellement en cours d'exécution, le flux d'Air planificateur va commencer à nouveau les tâches que vous supprimez. Donc, soit vous vous arrêtez le groupe d'abord par l'évolution de son état ou d'arrêter le planificateur (si vous êtes en cours d'exécution sur un environnement de test).
Si vous arrêtez le planificateur et vous ne voulez pas que la tâche à exécuter de nouveau, il suffit de définir la tâche manuellement à l'état de "succès" au lieu de la supprimer. Si vous venez de le supprimer, le planificateur va exécuter cette tâche à nouveau.
J'ai mis en pause le DAG et supprimé les dossiers, mais les processus sont toujours en cours d'exécution. Est-il un moyen de changer l'état conformément à l'interprète, mais aussi de tuer le processus sous-jacent?
OriginalL'auteur Jorge Almeida
de la circulation de l'air gitter (@villasv)
OriginalL'auteur Pablo
Comme menioned par Pablo et Jorge pause de la Dag ne va pas arrêter la tâche d'être exécuté si l'exécution a déjà commencé. Il y a cependant un moyen d'arrêter une tâche en cours d'exécution à partir de l'INTERFACE utilisateur, mais c'est un peu hacky.
Lorsque la tâche est sur
running
état, vous pouvez cliquer surCLEAR
cela appeljob.kill()
la tâche sera définie àshut_down
et a déménagé àup_for_retry
immédiatement d'où il est arrêté.Clairement la circulation de l'Air n'a pas pour but de vous à des tâches claires dans
Running
état toutefois, puisque la circulation de l'Air n'a pas le désactiver, soit vous pouvez l'utiliser comme je l'ai suggéré. La circulation de l'air signifiaitCLEAR
pour être utilisé avecfailed
,up_for_retry
etc... Peut-être dans l'avenir, la collectivité utilise ce bug(?) et de mettre en œuvre la présente comme une fonctionnalité à "arrêter la tâche".OriginalL'auteur Luis