code: def test_duplicate_group_id():
      from airflow.exceptions import DuplicateTaskIdFound
  
      execution_date = pendulum.parse("20200101")
  
      with pytest.raises(DuplicateTaskIdFound, match=r".* 'task1' .*"):
          with DAG(
              "test_duplicate_group_id", start_date=execution_date
          ):
              _ = EmptyOperator(task_id="task1")
              with TaskGroup("task1"):
                  pass
  
      with pytest.raises(DuplicateTaskIdFound, match=r".* 'group1' .*"):
          with DAG(
              "test_duplicate_group_id", start_date=execution_date
          ):
              _ = EmptyOperator(task_id="task1")
              with TaskGroup("group1", prefix_group_id=False):
                  with TaskGroup("group1"):
                      pass
  
      with pytest.raises(DuplicateTaskIdFound, match=r".* 'group1' .*"):
          with DAG(
              "test_duplicate_group_id", start_date=execution_date
          ):
              with TaskGroup("group1", prefix_group_id=False):
                  _ = EmptyOperator(task_id="group1")
  
      with pytest.raises(
          DuplicateTaskIdFound,
          match=r".* 'group1.downstream_join_id' .*",
      ):
          with DAG(
              "test_duplicate_group_id", start_date=execution_date
          ):
              _ = EmptyOperator(task_id="task1")
              with TaskGroup("group1"):
                  _ = EmptyOperator(task_id="downstream_join_id")
  
      with pytest.raises(
          DuplicateTaskIdFound, match=r".* 'group1.upstream_join_id' .*"
      ):
          with DAG(
              "test_duplicate_group_id", start_date=execution_date
          ):
              _ = EmptyOperator(task_id="task1")
              with TaskGroup("group1"):
                  _ = EmptyOperator(task_id="upstream_join_id")
  
imports: from __future__ import annotations
  from datetime import timedelta
  import pendulum
  import pytest
  from airflow.decorators import dag, setup, task, task_group, teardown
  from airflow.exceptions import TaskAlreadyInTaskGroup
  from airflow.models.baseoperator import BaseOperator
  from airflow.models.dag import DAG
  from airflow.models.xcom_arg import XComArg
  from airflow.operators.bash import BashOperator
  from airflow.operators.empty import EmptyOperator
  from airflow.operators.python import PythonOperator
  from airflow.utils.dag_edges import dag_edges
  from airflow.utils.task_group import TaskGroup, task_group_to_dict
  from tests.models import DEFAULT_DATE
label_desc: Use image node_id 11 for calling a global function with example usage: test_duplicate_group_id() without return types