The GitHub Actions job "Tests" on airflow.git has failed.
Run started by GitHub user ephraimbuddy (triggered by ephraimbuddy).

Head commit for run:
72d8d9ee663bd7785ca055c1336bacfd393e9fdb / Ephraim Anierobi 
<[email protected]>
Allow users to control baseoperator parameters in decorated task more

This opens up the possibility of using one decorated task
in different dag files.
Take for example the below task:
- common.py

@task(task_id='hello')
def hello():
    print('Hello')

defined in a file and called in different dag files using different task ids:
- dag_file1.py:
from common import hello

@dag()
def mydag():
    for i in range(3):
        hello(task_id=f'myhellotask_{i}')

- dag_file2.py:
from common import hello

@dag():
def mydag2():
    for i in range(3):
        hello(task_id=f'welcome_message_{i}')

They would all run with different task ids

ignore type

allow other baseoperator arguments

fixup! allow other baseoperator arguments

fixup! fixup! allow other baseoperator arguments

Report URL: https://github.com/apache/airflow/actions/runs/2156293183

With regards,
GitHub Actions via GitBox


---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to