jedcunningham commented on code in PR #22958:
URL: https://github.com/apache/airflow/pull/22958#discussion_r849969581
##########
airflow/api/common/mark_tasks.py:
##########
@@ -96,7 +96,8 @@ def set_state(
tasks that did not exist. It will not create dag runs that are missing
on the schedule (but it will as for subdag dag runs if needed).
- :param tasks: the iterable of tasks from which to work. task.task.dag
needs to be set
+ :param tasks: the iterable of tasks or task, map_index tuple from which to
work.
Review Comment:
```suggestion
:param tasks: the iterable of tasks or (task, map_index) tuples from
which to work.
```
nit
##########
airflow/models/dag.py:
##########
@@ -1789,6 +1817,8 @@ def clear(
:param session: The sqlalchemy session to use
:param dag_bag: The DagBag used to find the dags subdags (Optional)
:param exclude_task_ids: A set of ``task_id`` that should not be
cleared
+ :param exclude_task_ids_and_map_indexes: A set of
``task_id``,``map_index``
Review Comment:
```suggestion
:param exclude_task_ids_and_map_indexes: A set of ``(task_id,
map_index)``
```
--
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]
