AuthorWrite something about yourself. No need to be fancy, just an overview. ArchivesCategories |
Back to Blog
Airflow xcom1/28/2024 ![]() ![]() :type task_id: str :param dag_id: If provided, only pulls XCom from this DAG. :type key: str :param task_id: Only XComs from task with matching id will be pulled. If provided, only XComs with matching keys will be returned. :param execution_date: Execution date for the task :type execution_date: pendulum.datetime :param key: A key for the XCom. DateTime, key : Optional = None, task_id : Optional ]] = None, dag_id : Optional ]] = None, include_prior_dates : bool = False, session : Session = None, ) -> Optional : """ Retrieve an XCom value, optionally meeting certain criteria. def get_one ( cls, execution_date : pendulum. import json import logging import pickle from typing import Any, Iterable, Optional, Union import pendulum from sqlalchemy import Column, LargeBinary, String, and_ from sqlalchemy.orm import Query, Session, reconstructor from nfiguration import conf from import COLLATION_ARGS, ID_LEN, Base from airflow.utils import timezone from import is_container from _mixin import LoggingMixin from import provide_session from import UtcDateTime See the License for the # specific language governing permissions and limitations # under the License. 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.
0 Comments
Read More
Leave a Reply. |