+1 binding Vikram
On Mon, Jan 9, 2023 at 11:23 AM Ping Zhang <[email protected]> wrote: > +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> >>> >>
