Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Check for TaskGroup in _PythonDecoratedOperator #12312

Merged
merged 4 commits into from
Nov 15, 2020
Merged

Check for TaskGroup in _PythonDecoratedOperator #12312

merged 4 commits into from
Nov 15, 2020

Commits on Nov 14, 2020

  1. Check for TaskGroup in _PythonDecoratedOperator 

    Crucial feature of functions decorated by @task is to be able
to invoke them multiple times in single DAG. To do this we are
generating custom task_id for each invocation. However, this didn't
work with TaskGroup as the task_id is already altered by adding group_id
prefix. This PR fixes it.

closes: apache#12309
    @turbaszek
    turbaszek committed Nov 14, 2020
    Configuration menu
    Copy the full SHA
    2721444 View commit details
    Browse the repository at this point in the history

  2. Update airflow/operators/python.py 

    Co-authored-by: Kaxil Naik <[email protected]>
    @turbaszek @kaxil
    turbaszek and kaxil committed Nov 14, 2020
    Configuration menu
    Copy the full SHA
    a1cbac4 View commit details
    Browse the repository at this point in the history

  3. fixup! Check for TaskGroup in _PythonDecoratedOperator

    @turbaszek
    turbaszek committed Nov 14, 2020
    Configuration menu
    Copy the full SHA
    19ccc16 View commit details
    Browse the repository at this point in the history

  4. fixup! fixup! Check for TaskGroup in _PythonDecoratedOperator

    @turbaszek
    turbaszek committed Nov 14, 2020
    Configuration menu
    Copy the full SHA
    d1e8760 View commit details
    Browse the repository at this point in the history