astronomer.providers.google.cloud.operators.dataproc ==================================================== .. py:module:: astronomer.providers.google.cloud.operators.dataproc .. autoapi-nested-parse:: This module contains Google Dataproc operators. Classes ------- .. autoapisummary:: astronomer.providers.google.cloud.operators.dataproc.DataprocCreateClusterOperatorAsync astronomer.providers.google.cloud.operators.dataproc.DataprocDeleteClusterOperatorAsync astronomer.providers.google.cloud.operators.dataproc.DataprocSubmitJobOperatorAsync astronomer.providers.google.cloud.operators.dataproc.DataprocUpdateClusterOperatorAsync Module Contents --------------- .. py:class:: DataprocCreateClusterOperatorAsync(*, polling_interval = 5.0, **kwargs) Bases: :py:obj:`airflow.providers.google.cloud.operators.dataproc.DataprocCreateClusterOperator` This class is deprecated. Please use :class: `~airflow.providers.google.cloud.operators.dataproc.DataprocCreateClusterOperator` and set `deferrable` param to `True` instead. .. py:attribute:: is_deprecated :value: True .. py:attribute:: post_deprecation_replacement :value: 'from airflow.providers.google.cloud.operators.dataproc import DataprocCreateClusterOperator' .. py:class:: DataprocDeleteClusterOperatorAsync(*, polling_interval = 5.0, **kwargs) Bases: :py:obj:`airflow.providers.google.cloud.operators.dataproc.DataprocDeleteClusterOperator` This class is deprecated. Please use :class: `~airflow.providers.google.cloud.operators.dataproc.DataprocDeleteClusterOperator` and set `deferrable` param to `True` instead. .. py:attribute:: is_deprecated :value: True .. py:attribute:: post_deprecation_replacement :value: 'from airflow.providers.google.cloud.operators.dataproc import DataprocDeleteClusterOperator' .. py:class:: DataprocSubmitJobOperatorAsync(*args, **kwargs) Bases: :py:obj:`airflow.providers.google.cloud.operators.dataproc.DataprocSubmitJobOperator` This class is deprecated. Please use :class: `~airflow.providers.google.cloud.operators.dataproc.DataprocSubmitJobOperator` and set `deferrable` param to `True` instead. .. py:attribute:: is_deprecated :value: True .. py:attribute:: post_deprecation_replacement :value: 'from airflow.providers.google.cloud.operators.dataproc import DataprocSubmitJobOperator' .. py:class:: DataprocUpdateClusterOperatorAsync(*, polling_interval = 5.0, **kwargs) Bases: :py:obj:`airflow.providers.google.cloud.operators.dataproc.DataprocUpdateClusterOperator` This class is deprecated. Please use :class: `~airflow.providers.google.cloud.operators.dataproc.DataprocUpdateClusterOperator` and set `deferrable` param to `True` instead. .. py:attribute:: is_deprecated :value: True .. py:attribute:: post_deprecation_replacement :value: 'from airflow.providers.google.cloud.operators.dataproc import DataprocUpdateClusterOperator'