Add airflowctl tasks states-for-dag-run command#69366
Conversation
2f8b2d8 to
33e1f93
Compare
Signed-off-by: PoAn Yang <payang@apache.org>
33e1f93 to
4dafc6e
Compare
Backport failed to create: airflow-ctl/v0-1-test. View the failure log Run detailsNote: As of Merging PRs targeted for Airflow 3.X In matter of doubt please ask in #release-management Slack channel.
You can attempt to backport this manually by running: cherry_picker e9f89d6 airflow-ctl/v0-1-testThis should apply the commit to the airflow-ctl/v0-1-test branch and leave the commit in conflict state marking After you have resolved the conflicts, you can continue the backport process by running: cherry_picker --continueIf you don't have cherry-picker installed, see the installation guide. |
Backport failed to create: v3-3-test. View the failure log Run detailsNote: As of Merging PRs targeted for Airflow 3.X In matter of doubt please ask in #release-management Slack channel.
You can attempt to backport this manually by running: cherry_picker e9f89d6 v3-3-testThis should apply the commit to the v3-3-test branch and leave the commit in conflict state marking After you have resolved the conflicts, you can continue the backport process by running: cherry_picker --continueIf you don't have cherry-picker installed, see the installation guide. |
Resolve conflicts with the new tasks states-for-dag-run command (apache#69366): - keep both 'tasks state' (with --map-index) and 'tasks states-for-dag-run' in a single TASK_COMMANDS group - merge TaskInstancesOperations so it exposes both get() and list() - drop the TaskInstancesOperations exclusions so the auto-generated taskinstances group (get/list) stays available, add help text and an integration-test entry for 'taskinstances get' - regenerate command hashes and tasks/taskinstances help images
airflowctl tasks states-for-dag-run <dag_id> <logical_date_or_run_id>.TaskInstancesOperations.listinoperations.py(GET /dags/{dag_id}/dagRuns/{dag_run_id}/taskInstances), which also auto-generatesairflowctl taskinstances list <dag_id> <dag_run_id>.dags statetoairflowctl/ctl/utils/dag_run.py.@deprecated_for_airflowctl("airflowctl tasks states-for-dag-run")and register it intest_command_deprecations.py.Was generative AI tooling used to co-author this PR?
{pr_number}.significant.rst, in airflow-core/newsfragments. You can add this file in a follow-up commit after the PR is created so you know the PR number.