airflow.providers.amazon.aws.operators.redshift_cluster

Module Contents

Classes

RedshiftResumeClusterOperator

Resume a paused AWS Redshift Cluster

RedshiftPauseClusterOperator

Pause an AWS Redshift Cluster if it has status available.

class airflow.providers.amazon.aws.operators.redshift_cluster.RedshiftResumeClusterOperator(*, cluster_identifier: str, aws_conn_id: str = 'aws_default', **kwargs)[source]

Bases: airflow.models.BaseOperator

Resume a paused AWS Redshift Cluster

See also

For more information on how to use this operator, take a look at the guide: Resume a Redshift Cluster

Parameters
  • cluster_identifier (str) -- id of the AWS Redshift Cluster

  • aws_conn_id (str) -- aws connection to use

template_fields :Sequence[str] = ['cluster_identifier'][source]
ui_color = #eeaa11[source]
ui_fgcolor = #ffffff[source]
execute(self, context: airflow.utils.context.Context)[source]

This is the main method to derive when creating an operator. Context is the same dictionary used as when rendering jinja templates.

Refer to get_template_context for more context.

class airflow.providers.amazon.aws.operators.redshift_cluster.RedshiftPauseClusterOperator(*, cluster_identifier: str, aws_conn_id: str = 'aws_default', **kwargs)[source]

Bases: airflow.models.BaseOperator

Pause an AWS Redshift Cluster if it has status available.

See also

For more information on how to use this operator, take a look at the guide: Pause a Redshift Cluster

Parameters
  • cluster_identifier (str) -- id of the AWS Redshift Cluster

  • aws_conn_id (str) -- aws connection to use

template_fields :Sequence[str] = ['cluster_identifier'][source]
ui_color = #eeaa11[source]
ui_fgcolor = #ffffff[source]
execute(self, context: airflow.utils.context.Context)[source]

This is the main method to derive when creating an operator. Context is the same dictionary used as when rendering jinja templates.

Refer to get_template_context for more context.

Was this entry helpful?