astronomer.providers.google.cloud.operators.dataproc

This module contains Google Dataproc operators.

Classes

DataprocCreateClusterOperatorAsync

This class is deprecated.

DataprocDeleteClusterOperatorAsync

This class is deprecated.

DataprocSubmitJobOperatorAsync

This class is deprecated.

DataprocUpdateClusterOperatorAsync

This class is deprecated.

Module Contents

class astronomer.providers.google.cloud.operators.dataproc.DataprocCreateClusterOperatorAsync(*, polling_interval=5.0, **kwargs)[source]

Bases: 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.

is_deprecated = True
post_deprecation_replacement = 'from airflow.providers.google.cloud.operators.dataproc import DataprocCreateClusterOperator'
class astronomer.providers.google.cloud.operators.dataproc.DataprocDeleteClusterOperatorAsync(*, polling_interval=5.0, **kwargs)[source]

Bases: 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.

is_deprecated = True
post_deprecation_replacement = 'from airflow.providers.google.cloud.operators.dataproc import DataprocDeleteClusterOperator'
class astronomer.providers.google.cloud.operators.dataproc.DataprocSubmitJobOperatorAsync(*args, **kwargs)[source]

Bases: 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.

is_deprecated = True
post_deprecation_replacement = 'from airflow.providers.google.cloud.operators.dataproc import DataprocSubmitJobOperator'
class astronomer.providers.google.cloud.operators.dataproc.DataprocUpdateClusterOperatorAsync(*, polling_interval=5.0, **kwargs)[source]

Bases: 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.

is_deprecated = True
post_deprecation_replacement = 'from airflow.providers.google.cloud.operators.dataproc import DataprocUpdateClusterOperator'