+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] 
> <mailto:[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] <mailto:[email protected]>>
>>> Sent: Monday, January 9, 2023 8:27 AM
>>> To: [email protected] <mailto:[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()
>>> ```
>>> 

Reply via email to