#Airflow xcom delete software#
#Airflow xcom delete license#

Use :meth:`get_many` if you want the 'shortened' value via ``orm_deserialize_value``. uses ``deserialize_value`` from the XCom backend). This method returns 'full' XCom values (i.e. map_index, session = session, ) def get_one ( *, key : str | None = None, dag_id : str | None = None, task_id : str | None = None, run_id : str | None = None, map_index : int | None = None, session : Session = NEW_SESSION, ) -> Any | None : '''Retrieve an XCom value, optionally meeting certain criteria. If not given, a new session will be created for this function. Pass *None* (default) to remove the filter. If provided, only XCom with matching keys will be returned. :param ti_key: The TaskInstanceKey to look up the XCom for. If multiple XCom entries match the criteria, an arbitrary one is returned. If there are no results, *None* is returned.

flush () def get_value ( *, ti_key : TaskInstanceKey, key : str | None = None, session : Session = NEW_SESSION, ) -> Any : '''Retrieve an XCom value for a task instance. dag_run_id = dag_run_id, key = key, value = value, run_id = run_id, task_id = task_id, dag_id = dag_id, map_index = map_index, ) session. delete () new = cast ( Any, cls )( # Work around Mypy complaining model not defining '_init_'. serialize_value ( value = value, key = key, task_id = task_id, dag_id = dag_id, run_id = run_id, map_index = map_index, ) # Remove duplicate XComs and insert a new one.

' f 'Passed execution_date= ', task_id, dag_id, run_id or execution_date, ) value = list ( value ) value = cls. datetime | None = None, session : Session = NEW_SESSION, *, run_id : str | None = None, map_index : int = - 1, ) -> None : ''':sphinx-autoapi-skip:''' from import DagRun if not exactly_one ( execution_date is not None, run_id is not None ): raise ValueError ( f 'Exactly one of run_id or execution_date must be passed. datetime, session : Session = NEW_SESSION, ) -> None : ''':sphinx-autoapi-skip:''' def set ( cls, key : str, value : Any, task_id : str, dag_id : str, execution_date : datetime. ''' def set ( cls, key : str, value : Any, task_id : str, dag_id : str, execution_date : datetime. The default is ``-1`` (set for a non-mapped task). :param map_index: Optional map index to assign XCom for a mapped task. The two arguments are mutually exclusive. A deprecated form of this function accepts ``execution_date`` instead of ``run_id``. map_index ' return f '' def set ( cls, key : str, value : Any, *, dag_id : str, task_id : str, run_id : str, map_index : int = - 1, session : Session = NEW_SESSION, ) -> None : '''Store an XCom value. from _future_ import annotations import collections.abc import contextlib import datetime import inspect import itertools import json import logging import pickle import warnings from functools import wraps from typing import TYPE_CHECKING, Any, Generator, Iterable, cast, overload import attr import pendulum from sqlalchemy import ( Column, ForeignKe圜onstraint, Index, Integer, LargeBinary, PrimaryKe圜onstraint, String, text, ) from import association_proxy from sqlalchemy.orm import Query, Session, reconstructor, relationship from import NoResultFound from airflow import settings from airflow.api_internal.internal_api_call import internal_api_call from import cached_property from nfiguration import conf from airflow.exceptions import RemovedInAirflow3Warning from import COLLATION_ARGS, ID_LEN, Base from airflow.utils import timezone from import exactly_one, is_container from import XComDecoder, XComEncoder from _mixin import LoggingMixin from import NEW_SESSION, provide_session from import UtcDateTime # XCom constants below are needed for providers backward compatibility, # which should import the constants directly after apache-airflow>=2.6.0 from import ( MAX_XCOM_SIZE, # noqa: F401 XCOM_RETURN_KEY, )

#Airflow xcom delete license#

See the License for the # specific language governing permissions and limitations # under the License.

#Airflow xcom delete software#

You may obtain a copy of the License at # Unless required by applicable law or agreed to in writing, # software distributed under the License is distributed on an # 'AS IS' BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY # KIND, either express or implied. The ASF licenses this file # to you under the Apache License, Version 2.0 (the # 'License') you may not use this file except in compliance # with the License. See the NOTICE file # distributed with this work for additional information # regarding copyright ownership. # Licensed to the Apache Software Foundation (ASF) under one # or more contributor license agreements.