+1 (binding) On Mon, Jan 9, 2023 at 7:07 PM Jarek Potiuk <ja...@potiuk.com> wrote:
> +1 (binding) > > On Mon, Jan 9, 2023 at 6:01 PM Ferruzzi, Dennis > <ferru...@amazon.com.invalid> wrote: > >> +1 non-binding >> >> ------------------------------ >> *From:* Ash Berlin-Taylor <a...@apache.org> >> *Sent:* Monday, January 9, 2023 8:27 AM >> *To:* dev@airflow.apache.org >> *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() >> ``` >> >>
