airflow.contrib.operators.bigquery_table_delete_operator

Module Contents

class airflow.contrib.operators.bigquery_table_delete_operator.BigQueryTableDeleteOperator(deletion_dataset_table, bigquery_conn_id='bigquery_default', delegate_to=None, ignore_if_missing=False, *args, **kwargs)[source]

Bases: airflow.models.BaseOperator

Deletes BigQuery tables

Parameters

  • deletion_dataset_table (str) – A dotted (<project>.|<project>:)<dataset>.<table> that indicates which table will be deleted. (templated)

  • bigquery_conn_id (str) – reference to a specific BigQuery hook.

  • delegate_to (str) – The account to impersonate, if any. For this to work, the service account making the request must have domain-wide delegation enabled.

  • ignore_if_missing (bool) – if True, then return success even if the requested table does not exist.

template_fields = ['deletion_dataset_table'][source]
ui_color = #ffd1dc[source]
execute(self, context)[source]

Was this entry helpful?