tjhub1983 commented on PR #66218:
URL: https://github.com/apache/airflow/pull/66218#issuecomment-4363453968
Thanks for the review! Pushed a new commit that:
1. **Added `TaskOperations` class** to `operations.py` with
`states_for_dag_run(dag_id, dag_run_id, limit)` method, following the same
pattern as `DagRunOperations` and other operation classes.
2. **Updated `task_command.py`** to use `TaskOperations` instead of raw
`api_client.client.get()` calls.
3. **Added `TestTaskOperations`** unit test in
`tests/airflow_ctl/api/test_operations.py` verifying the correct endpoint path
and limit param.
4. **Added integration tests** in
`airflow-ctl-tests/tests/airflowctl_tests/test_airflowctl_commands.py`:
- `tasks states-for-dag-run --dag-id=example_bash_operator
--dag-run-id=run_1 --limit=5`
- `tasks clear --dag-id=example_bash_operator --dag-run-id=run_1`
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
