astro.sql.operators.drop

Module Contents

Classes

DropTableOperator

Airflow Operator for dropping SQL tables.

Functions

drop_table(table, **kwargs)

Drops a table.

class astro.sql.operators.drop.DropTableOperator(table, task_id='', **kwargs)

Bases: airflow.models.BaseOperator

Airflow Operator for dropping SQL tables.

Parameters

• table (astro.sql.table.Table) –

• task_id (str) –

template_fields = ['table']

execute(context)

Method run when the Airflow runner calls the operator.

Parameters

context (dict) –

Return type

astro.sql.table.Table

astro.sql.operators.drop.drop_table(table, **kwargs)

Drops a table.

Parameters

• table (astro.sql.table.Table) – Table to be dropped

• kwargs (Any) – Any keyword arguments supported by the BaseOperator is supported (e.g queue, owner)

Return type

airflow.models.xcom_arg.XComArg