"""Used to store info needed to create XComArg.
    We can't turn it in to a XComArg until we've loaded _all_ the tasks, so when
    deserializing an operator, we need to create something in its place, and
    post-process it in ``deserialize_dag``.
    """
    data: dict
    def deref(self, dag: DAG) -> XComArg:
        return deserialize_xcom_arg(self.data, dag)
_ExpandInputOriginalValue = Union[
    
    Mapping[str, Any],
    
    XComArg,
    Collection[Union[XComArg, Mapping[str, Any]]],
]
_ExpandInputSerializedValue = Union[
    
    Mapping[str, Any],
    
    _XComRef,
    Collection[Union[_XComRef, Mapping[str, Any]]],
]
class _ExpandInputRef(NamedTuple):