astro.sql.operators.truncate

Module Contents

Classes

TruncateOperator

Airflow Operator for truncating SQL tables.

class astro.sql.operators.truncate.TruncateOperator(table, task_id='', **kwargs)

Bases: airflow.models.BaseOperator

Airflow Operator for truncating SQL tables.

Parameters

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

• task_id (str) –

execute(context)

Method run when the Airflow runner calls the operator.

Parameters

context (Dict) –

Return type

None