'Verifies the VACUUM operation runs well with the PostgresOperator'

def test_vacuum(self):

    import airflow.operators.postgres_operator
    sql = 'VACUUM    ANALYZE;'
    t = operators.postgres_operator.PostgresOperator(task_id='postgres_operator_test_vacuum', sql=sql, dag=self.dag, autocommit=True)
    t.run(start_date=DEFAULT_DATE, end_date=DEFAULT_DATE, ignore_ti_state=True)
