Such as transmission a large amount of XCom to TaskAPI. It can be set to False to prevent log output of return value when you return huge data Defaults to True, which allows return value log output. Show_return_value_in_logs ( bool) – a bool value whether to show return_value Processing templated fields, for examples Templates_exts ( Sequence | None) – a list of file extensions to resolve while In your callable’s context after the template has been applied. _init_ and execute takes place and are made available Will get templated by the Airflow engine sometime between Templates_dict ( dict | None) – a dictionary where the values are templates that Op_args ( Collection | None) – a list of positional arguments that will get unpacked when Op_kwargs ( Mapping | None) – a dictionary of keyword arguments that will get unpacked Python_callable ( Callable) – A reference to an object that is callable PythonOperator ( *, python_callable, op_args = None, op_kwargs = None, templates_dict = None, templates_exts = None, show_return_value_in_logs = True, ** kwargs ) ¶īases: ĭef my_python_callable ( ** kwargs ): ti = kwargs next_ds = kwargs Parameters Dict will unroll to xcom values with keys as keys.Ĭlass. Multiple_outputs ( bool | None) – if set, function return value will be Op_args – a list of positional arguments that will get unpacked when Op_kwargs – a dictionary of keyword arguments that will get unpacked Python_callable ( Callable | None) – A reference to an object that is callable task ( python_callable = None, multiple_outputs = None, ** kwargs ) ¶Ĭalls and allows users to turn a Python function into Whichever way of checking it works, is fine. is_venv_installed ( ) ¶Ĭheck if the virtualenv package is installed via checking if it is on the path or installed as package. Retrieve the execution context dictionary without altering user method's signature.Ī. What is not part of the Public Interface of Apache Airflow?Ĭheck if the virtualenv package is installed via checking if it is on the path or installed as package.Using Public Interface to integrate with external services and applications.Using Public Interface to extend Airflow capabilities.ExternalPythonOperator.execute_callable().
PythonVirtualenvOperator.execute_callable().PythonVirtualenvOperator.template_fields.PythonOperator.template_fields_renderers.Using the Public Interface for DAG Authors.
0 kommentar(er)
