Airflow xcom pull return nonetype software#
Airflow xcom pull return nonetype code#
Airflow xcom pull return nonetype license#

(templated) 96 :param force_pull: Pull the docker image on every run. 95 Overridden by variables in the environment parameter. env file with environment variables to set in the container. 94 :param env_file: Relative path to the. 93 These are not templated, and hidden from the website. (templated) 92 :param private_environment: Private environment variables to set in the container. 90 Default is unix://var/run/docker.sock 91 :param environment: Environment variables to set in the container. See 88 89 :param docker_url: URL of the host running the docker daemon. Optional (templated) 86 :param cpus: Number of CPUs to assign to the container. (templated) 85 :param container_name: Name of the container. 84 :param command: Command to be run in the container. Set to ``auto`` to automatically 83 detect the server's version. (templated) 82 :param api_version: Remote API version. 81 If image tag is omitted, 'latest' will be used. 79 80 :param image: Docker image from which to create the container. In this case, you can still use 72 ``mounts`` parameter to mount already existing named volumes in your Docker Engine 73 to achieve similar capability where you can store files exceeding default disk size 74 of the container, 75 76 If a login to a private registry is required prior to pulling the image, a 77 Docker connection needs to be configured in Airflow and the connection ID 78 be provided with the parameter ``docker_conn_id``. 69 70 If you know you run DockerOperator with remote engine or via docker-in-docker 71 you should set ``mount_tmp_dir`` parameter to False. This is to make it works by default with remote docker 67 engine or when you run docker-in-docker solution and temporary directory is not shared with the 68 docker engine. 64 65 If the volume cannot be mounted, warning is printed and an attempt is made to execute the docker 66 command without the temporary folder mounted. 62 In this case The path to the mounted directory can be accessed 63 via the environment variable ``AIRFLOW_TMP_DIR``. 58 59 By default, a temporary directory is 60 created on the host and mounted into a container to allow storing files 61 that together exceed the default disk size of 10GB in a container. Docker stream can return bytes.''' 49 decode_method = getattr (line, 'decode', None ) 50 if decode_method : 51 return decode_method (encoding = 'utf-8', errors = 'surrogateescape' ) 52 else : 53 return line 54 55 56 class DockerOperator (BaseOperator ): 57 '''Execute a command inside a docker container. context import Context 45 46 47 def stringify (line : str | bytes ): 48 '''Make sure string is returned even if bytes are passed. types import DeviceRequest 43 44 from airflow. docker import DockerHook 39 40 if TYPE_CHECKING : 41 from docker import APIClient 42 from docker.

models import BaseOperator 38 from airflow.

exceptions import AirflowException, AirflowProviderDeprecationWarning, AirflowSkipException 37 from airflow. types import LogConfig, Mount 34 from dotenv import dotenv_values 35 36 from airflow. constants import DEFAULT_TIMEOUT_SECONDS 32 from docker. abc import Container 26 from functools import cached_property 27 from io import BytesIO, StringIO 28 from tempfile import TemporaryDirectory 29 from typing import TYPE_CHECKING, Iterable, Sequence 30 31 from docker. 18 '''Implements Docker operator.''' 19 from _future_ import annotations 20 21 import ast 22 import pickle 23 import tarfile 24 import warnings 25 from collections.

Airflow xcom pull return nonetype license#

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

Airflow xcom pull return nonetype software#

You may obtain a copy of the License at 9 # 10 # 11 # 12 # Unless required by applicable law or agreed to in writing, 13 # software distributed under the License is distributed on an 14 # 'AS IS' BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY 15 # KIND, either express or implied.

The ASF licenses this file 6 # to you under the Apache License, Version 2.0 (the 7 # 'License') you may not use this file except in compliance 8 # with the License. See the NOTICE file 4 # distributed with this work for additional information 5 # regarding copyright ownership.

Airflow xcom pull return nonetype code#

As a special service 'Fossies' has tried to format the requested source page into HTML format using (guessed) Python source code syntax highlighting (style: standard) with prefixed line numbers.Īlternatively you can here view or download the uninterpreted source code file.įor more information about 'docker.py' see the Fossies 'Dox' file reference documentation and the last Fossies 'Diffs' side-by-side code changes report: 2.7.1_vs_2.7.2.ġ # 2 # Licensed to the Apache Software Foundation (ASF) under one 3 # or more contributor license agreements.