uranusjr commented on code in PR #31153:
URL: https://github.com/apache/airflow/pull/31153#discussion_r1191959105
##########
airflow/models/skipmixin.py:
##########
@@ -60,17 +61,24 @@ class SkipMixin(LoggingMixin):
def _set_state_to_skipped(
self,
dag_run: DagRun | DagRunPydantic,
- tasks: Iterable[Operator],
+ tasks: Iterable[str] | Iterable[tuple[str, int]],
session: Session,
+ include_map_index: bool = False,
Review Comment:
The combination of these arguments is weird. If you don’t want to include
map indexes, just don’t pass them? An `isinstance` check on `tasks` would be
sufficient instead of a separate flag.
--
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]
