Airflow virtualenv operator12/23/2023 Dict will unroll to XCom values with keys as XCom keys. :param multiple_outputs: If set, function return value will be unrolled to multiple XCom values. image : str, api_version : str | None = None, container_name : str | None = None, cpus : float = 1.0, docker_url : str = "unix://var/run/docker.sock", environment : dict | None = None, private_environment : dict | None = None, force_pull : bool = False, mem_limit : float | str | None = None, host_tmp_dir : str | None = None, network_mode : str | None = None, tls_ca_cert : str | None = None, tls_client_cert : str | None = None, tls_client_key : str | None = None, tls_hostname : str | bool | None = None, tls_ssl_version : str | None = None, tmp_dir : str = "/tmp/airflow", user : str | int | None = None, mounts : list | None = None, working_dir : str | None = None, xcom_all : bool = False, docker_conn_id : str | None = None, dns : list | None = None, dns_search : list | None = None, auto_remove : bool = False, shm_size : int | None = None, tty : bool = False, privileged : bool = False, cap_add : str | None = None, extra_hosts : dict | None = None, ** kwargs, ) -> TaskDecorator : """Create a decorator to convert the decorated callable to a Docker task. python_command : str = "python3", # 'command', 'retrieve_output', and 'retrieve_output_path' are filled by # _DockerDecoratedOperator. Export dynamic environment variables available for operators to useĭef docker ( self, *, multiple_outputs : bool | None = None, use_dill : bool = False, # Added by _DockerDecoratedOperator.(Optional) Adding IDE auto-completion support.Customize view of Apache from Airflow web UI.Customizing DAG Scheduling with Timetables.Configuring Flask Application for Airflow Webserver.Add tags to DAGs and use it for filtering in the UI.
0 Comments
Leave a Reply.AuthorWrite something about yourself. No need to be fancy, just an overview. ArchivesCategories |