ashb commented on code in PR #45627: URL: https://github.com/apache/airflow/pull/45627#discussion_r1914640449
########## airflow/models/xcom_arg.py: ########## @@ -17,714 +17,100 @@ from __future__ import annotations -import contextlib -import inspect -import itertools -from collections.abc import Iterable, Iterator, Mapping, Sequence -from typing import TYPE_CHECKING, Any, Callable, Union, overload +from functools import singledispatch +from typing import TYPE_CHECKING from sqlalchemy import func, or_, select - -from airflow.exceptions import AirflowException, XComNotFound -from airflow.models import MappedOperator, TaskInstance -from airflow.models.abstractoperator import AbstractOperator -from airflow.models.taskmixin import DependencyMixin -from airflow.sdk.definitions._internal.mixins import ResolveMixin -from airflow.sdk.definitions._internal.types import NOTSET, ArgNotSet +from sqlalchemy.orm import Session + +from airflow.sdk.definitions._internal.types import ArgNotSet +from airflow.sdk.definitions.mappedoperator import MappedOperator +from airflow.sdk.definitions.xcom_arg import ( + ConcatXComArg, + MapXComArg, + PlainXComArg, + XComArg as XComArg, Review Comment: It was called DBXcomArg at one point in the life of this PR but I didn't correct this -- 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]
