airflow.providers.google.cloud.operators.cloud_base¶

This module contains a Google API base operator.

Classes¶

GoogleCloudBaseOperator

Abstract base class for operators using Google API client libraries.

Module Contents¶

class airflow.providers.google.cloud.operators.cloud_base.GoogleCloudBaseOperator(*, task_id, owner=DEFAULT_OWNER, email=None, email_on_retry=True, email_on_failure=True, retries=DEFAULT_RETRIES, retry_delay=DEFAULT_RETRY_DELAY, retry_exponential_backoff=False, max_retry_delay=None, start_date=None, end_date=None, depends_on_past=False, ignore_first_depends_on_past=DEFAULT_IGNORE_FIRST_DEPENDS_ON_PAST, wait_for_past_depends_before_skipping=DEFAULT_WAIT_FOR_PAST_DEPENDS_BEFORE_SKIPPING, wait_for_downstream=False, dag=None, params=None, default_args=None, priority_weight=DEFAULT_PRIORITY_WEIGHT, weight_rule=DEFAULT_WEIGHT_RULE, queue=DEFAULT_QUEUE, pool=None, pool_slots=DEFAULT_POOL_SLOTS, sla=None, execution_timeout=DEFAULT_TASK_EXECUTION_TIMEOUT, on_execute_callback=None, on_failure_callback=None, on_success_callback=None, on_retry_callback=None, on_skipped_callback=None, pre_execute=None, post_execute=None, trigger_rule=DEFAULT_TRIGGER_RULE, resources=None, run_as_user=None, map_index_template=None, max_active_tis_per_dag=None, max_active_tis_per_dagrun=None, executor=None, executor_config=None, do_xcom_push=True, multiple_outputs=False, inlets=None, outlets=None, task_group=None, doc=None, doc_md=None, doc_json=None, doc_yaml=None, doc_rst=None, task_display_name=None, logger_name=None, allow_nested_operators=True, **kwargs)[source]¶

Bases: airflow.providers.google.version_compat.BaseOperator

Abstract base class for operators using Google API client libraries.

__deepcopy__(memo)[source]¶

Update the memo to fix the non-copyable global constant.

This constant can be specified in operator parameters as a retry configuration to indicate a default. See https://github.com/apache/airflow/issues/28751 for details.

property extra_links_params: dict[str, Any][source]¶

Override this method to include parameters for link formatting in extra links.

For example; most of the links on the Google provider require project_id and location in the Link. To be not repeat; you can override this function and return something like the following:

{
    "project_id": self.project_id,
    "location": self.location,
}