VBhojawala commented on a change in pull request #12228:
URL: https://github.com/apache/airflow/pull/12228#discussion_r550747918
##########
File path: airflow/utils/task_group.py
##########
@@ -344,3 +357,52 @@ def get_current_task_group(cls, dag: Optional["DAG"]) ->
Optional[TaskGroup]:
return dag.task_group
return cls._context_managed_task_group
+
+
+T = TypeVar("T", bound=Callable) # pylint: disable=invalid-name
+
+
+def taskgroup(python_callable: Optional[Callable] = None, *tg_args,
**tg_kwargs) -> Callable[[T], T]:
+ """
+ Python TaskGroup decorator. Wraps a function into an Airflow TaskGroup.
+ Accepts kwargs for operator TaskGroup. Can be used to parametrize
TaskGroup.
+
+ :param python_callable: Function to decorate
+ :param tg_args: Arguments for TaskGroup object
+ :type tg_args: list
+ :param tg_kwargs: Kwargs for TaskGroup object.
+ :type tg_kwargs: dict
+ """
+
+ def wrapper(f: T):
+ # Setting group_id as function name if not given
+ if len(tg_args) == 0 and 'group_id' not in tg_kwargs.keys():
+ tg_kwargs['group_id'] = f.__name__
Review comment:
Sure, can you guide me how to get list of existing group_id inside
taskgroup decorator?
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
