Task Instance Queue Not Preserved on Clear #25320
Unanswered
JGoldman110
asked this question in
General
Replies: 2 comments 1 reply
-
@milton0825 any thoughts on this? |
Beta Was this translation helpful? Give feedback.
0 replies
-
There is already an issue about it. #20143 . You can chime in there. |
Beta Was this translation helpful? Give feedback.
1 reply
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
-
Currently we have a
task_instance_mutation_hook
which dynamically changes the queue a task instance is assigned to based on if the task instance is a scheduled or manual run. This works well, except for when a user clears a task instance.When clearing a task instance the
task_instance_mutation_hook
is not called. Instead when clearing a task instance the task instance is refreshed and the original queue assigned to that task instance in thetask_instance_mutation_hook
is overridden and set to the default queue defined in the operator or the default queue set in airflow configs.Does it make sense to also call the
task_instance_mutation_hook
on clear as well? or to preserve the original queue on the task instance on clear? Or maybe there is another hook to modify task_instance queue on clear that I am not aware of?Beta Was this translation helpful? Give feedback.
All reactions