+1 binding Thanks,
Ping On Mon, Jan 9, 2023 at 11:22 AM Ephraim Anierobi <[email protected]> wrote: > +1 binding > > On Mon, 9 Jan 2023 at 19:55, Frank Cash <[email protected]> wrote: > >> +1 (non-binding) >> >> On Mon, Jan 9, 2023 at 1:34 PM Josh Fell >> <[email protected]> wrote: >> >>> +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() >>>>>> ``` >>>>>> >>>>>> >>>> >> >> -- >> Charles Frank Cash >> https://github.com/frankcash >> https://keybase.io/frankcash >> <https://github.com/frankcash> >> >
