+1 (binding) On Mon, Jan 9, 2023 at 6:01 PM Ferruzzi, Dennis <[email protected]> wrote:
> +1 non-binding > > ------------------------------ > *From:* Ash Berlin-Taylor <[email protected]> > *Sent:* Monday, January 9, 2023 8:27 AM > *To:* [email protected] > *Subject:* [EXTERNAL] [VOTE] AIP-52 Automatic setup and teardown tasks > > > *CAUTION*: This email originated from outside of the organization. Do not > click links or open attachments unless you can confirm the sender and know > the content is safe. > > Hello everyone, > > I am calling for a vote on AIP-52 > https://cwiki.apache.org/confluence/display/AIRFLOW/AIP-52+Automatic+setup+and+teardown+tasks > There haven't been any notable changes to the original document, mostly > just clairifications to the proposal. > > This is my +1, and the vote will last until 10am (UTC) on Monday 16th > January. > > Thanks, > Ash > (To remind people what this is about, here is the example from the first > dicuss email) > > ``` > from airflow import DAG, task, setup, teardown > > > with DAG(dag_id='test'): > @setup > def create_cluster(): > ... > return cluster_id > > @task > def load(ti): > # Example: > cluster_id = ti.xcom_pull(task_id="create_cluster") > > def summarize(): > ... > > @teardown(on_failure_fail_dagrun=False) > def teardown_cluster(): > ... > cluster_id = ti.xcom_pull(task_id="create_cluster") > > create_cluster() > load() >> summarize() > teardown_cluster() > ``` > >
