+1 (binding) Le lun. 9 janv. 2023 à 21:12, Vikram Koka <vik...@astronomer.io.invalid> a écrit :
> +1 binding > > Vikram > > > On Mon, Jan 9, 2023 at 11:23 AM Ping Zhang <pin...@umich.edu> wrote: > >> +1 binding >> >> Thanks, >> >> Ping >> >> >> On Mon, Jan 9, 2023 at 11:22 AM Ephraim Anierobi < >> ephraimanier...@gmail.com> wrote: >> >>> +1 binding >>> >>> On Mon, 9 Jan 2023 at 19:55, Frank Cash <cash.fra...@gmail.com> wrote: >>> >>>> +1 (non-binding) >>>> >>>> On Mon, Jan 9, 2023 at 1:34 PM Josh Fell >>>> <josh.d.f...@astronomer.io.invalid> wrote: >>>> >>>>> +1 binding >>>>> >>>>> On Mon, Jan 9, 2023 at 12:51 PM Drew Hubl >>>>> <drew.h...@astronomer.io.invalid> wrote: >>>>> >>>>>> +1 (non-binding) >>>>>> >>>>>> On Jan 9, 2023, at 10:10 AM, Elad Kalif <elad...@apache.org> wrote: >>>>>> >>>>>> +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() >>>>>>>> ``` >>>>>>>> >>>>>>>> >>>>>> >>>> >>>> -- >>>> Charles Frank Cash >>>> https://github.com/frankcash >>>> https://keybase.io/frankcash >>>> <https://github.com/frankcash> >>>> >>>
