+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> >
