+1 binding On Mon, Jan 9, 2023 at 12:51 PM Drew Hubl <[email protected]> wrote:
> +1 (non-binding) > > On Jan 9, 2023, at 10:10 AM, Elad Kalif <[email protected]> wrote: > > +1 (binding) > > On Mon, Jan 9, 2023 at 7:07 PM Jarek Potiuk <[email protected]> wrote: > >> +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() >>> ``` >>> >>> >
