google.api_core.exceptions.Conflict: 409 POST https://bigquery.googleapis.com/bigquery/v2/projects/apache-beam-testing/datasets/python_write_to_table_17827520083b0f4d/tables?prettyPrint=false: Already Exists: Table apache-beam-testing:python_write_to_table_17827520083b0f4d.python_append_schema_update
a = (<apache_beam.io.gcp.bigquery_write_it_test.BigQueryWriteIntegrationTests testMethod=test_big_query_write_temp_table_append_schema_update_1>,)
kw = {}

    @wraps(func)
    def standalone_func(*a, **kw):
>       return func(*(a + p.args), **p.kwargs, **kw)
               ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^

../../build/gradleenv/417525525/lib/python3.12/site-packages/parameterized/parameterized.py:620: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
../../build/gradleenv/417525525/lib/python3.12/site-packages/mock/mock.py:1468: in patched
    return func(*newargs, **newkeywargs)
           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
../../build/gradleenv/417525525/lib/python3.12/site-packages/parameterized/parameterized.py:93: in dummy_func
    return orgfunc(*args, **kwargs)
           ^^^^^^^^^^^^^^^^^^^^^^^^
../../build/gradleenv/417525525/lib/python3.12/site-packages/mock/mock.py:1468: in patched
    return func(*newargs, **newkeywargs)
           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
../../build/gradleenv/417525525/lib/python3.12/site-packages/tenacity/__init__.py:331: in wrapped_f
    return copy(f, *args, **kw)
           ^^^^^^^^^^^^^^^^^^^^
../../build/gradleenv/417525525/lib/python3.12/site-packages/tenacity/__init__.py:470: in __call__
    do = self.iter(retry_state=retry_state)
         ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
../../build/gradleenv/417525525/lib/python3.12/site-packages/tenacity/__init__.py:371: in iter
    result = action(retry_state)
             ^^^^^^^^^^^^^^^^^^^
../../build/gradleenv/417525525/lib/python3.12/site-packages/tenacity/__init__.py:413: in exc_check
    raise retry_exc.reraise()
          ^^^^^^^^^^^^^^^^^^^
../../build/gradleenv/417525525/lib/python3.12/site-packages/tenacity/__init__.py:184: in reraise
    raise self.last_attempt.result()
          ^^^^^^^^^^^^^^^^^^^^^^^^^^
/opt/hostedtoolcache/Python/3.12.13/x64/lib/python3.12/concurrent/futures/_base.py:449: in result
    return self.__get_result()
           ^^^^^^^^^^^^^^^^^^^
/opt/hostedtoolcache/Python/3.12.13/x64/lib/python3.12/concurrent/futures/_base.py:401: in __get_result
    raise self._exception
../../build/gradleenv/417525525/lib/python3.12/site-packages/tenacity/__init__.py:473: in __call__
    result = fn(*args, **kwargs)
             ^^^^^^^^^^^^^^^^^^^
apache_beam/io/gcp/bigquery_write_it_test.py:513: in test_big_query_write_temp_table_append_schema_update
    self.create_table(table_name)
apache_beam/io/gcp/bigquery_write_it_test.py:99: in create_table
    self.bigquery_client.client.create_table(table)
../../build/gradleenv/417525525/lib/python3.12/site-packages/google/cloud/bigquery/client.py:827: in create_table
    api_response = self._call_api(
../../build/gradleenv/417525525/lib/python3.12/site-packages/google/cloud/bigquery/client.py:861: in _call_api
    return call()
           ^^^^^^
../../build/gradleenv/417525525/lib/python3.12/site-packages/google/api_core/retry/retry_unary.py:294: in retry_wrapped_func
    return retry_target(
../../build/gradleenv/417525525/lib/python3.12/site-packages/google/api_core/retry/retry_unary.py:156: in retry_target
    next_sleep = _retry_error_helper(
../../build/gradleenv/417525525/lib/python3.12/site-packages/google/api_core/retry/retry_base.py:216: in _retry_error_helper
    raise final_exc from source_exc
../../build/gradleenv/417525525/lib/python3.12/site-packages/google/api_core/retry/retry_unary.py:147: in retry_target
    result = target()
             ^^^^^^^^
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

self = <google.cloud.bigquery._http.Connection object at 0x7cffbc7a96a0>
method = 'POST'
path = '/projects/apache-beam-testing/datasets/python_write_to_table_17827520083b0f4d/tables'
query_params = None
data = '{"tableReference": {"projectId": "apache-beam-testing", "datasetId": "python_write_to_table_17827520083b0f4d", "table...LABLE"}, {"name": "date", "type": "DATE", "mode": "NULLABLE"}, {"name": "time", "type": "TIME", "mode": "NULLABLE"}]}}'
content_type = 'application/json', headers = None, api_base_url = None
api_version = None, expect_json = True, _target_object = None, timeout = None
extra_api_info = None

    def api_request(
        self,
        method,
        path,
        query_params=None,
        data=None,
        content_type=None,
        headers=None,
        api_base_url=None,
        api_version=None,
        expect_json=True,
        _target_object=None,
        timeout=_DEFAULT_TIMEOUT,
        extra_api_info=None,
    ):
        """Make a request over the HTTP transport to the API.
    
        You shouldn't need to use this method, but if you plan to
        interact with the API using these primitives, this is the
        correct one to use.
    
        :type method: str
        :param method: The HTTP method name (ie, ``GET``, ``POST``, etc).
                       Required.
    
        :type path: str
        :param path: The path to the resource (ie, ``'/b/bucket-name'``).
                     Required.
    
        :type query_params: dict or list
        :param query_params: A dictionary of keys and values (or list of
                             key-value pairs) to insert into the query
                             string of the URL.
    
        :type data: str
        :param data: The data to send as the body of the request. Default is
                     the empty string.
    
        :type content_type: str
        :param content_type: The proper MIME type of the data provided. Default
                             is None.
    
        :type headers: dict
        :param headers: extra HTTP headers to be sent with the request.
    
        :type api_base_url: str
        :param api_base_url: The base URL for the API endpoint.
                             Typically you won't have to provide this.
                             Default is the standard API base URL.
    
        :type api_version: str
        :param api_version: The version of the API to call.  Typically
                            you shouldn't provide this and instead use
                            the default for the library.  Default is the
                            latest API version supported by
                            google-cloud-python.
    
        :type expect_json: bool
        :param expect_json: If True, this method will try to parse the
                            response as JSON and raise an exception if
                            that cannot be done.  Default is True.
    
        :type _target_object: :class:`object`
        :param _target_object:
            (Optional) Protected argument to be used by library callers. This
            can allow custom behavior, for example, to defer an HTTP request
            and complete initialization of the object at a later time.
    
        :type timeout: float or tuple
        :param timeout: (optional) The amount of time, in seconds, to wait
            for the server response.
    
            Can also be passed as a tuple (connect_timeout, read_timeout).
            See :meth:`requests.Session.request` documentation for details.
    
        :type extra_api_info: string
        :param extra_api_info: (optional) Extra api info to be appended to
            the X-Goog-API-Client header
    
        :raises ~google.cloud.exceptions.GoogleCloudError: if the response code
            is not 200 OK.
        :raises ValueError: if the response content type is not JSON.
        :rtype: dict or str
        :returns: The API response payload, either as a raw string or
                  a dictionary if the response is valid JSON.
        """
        url = self.build_api_url(
            path=path,
            query_params=query_params,
            api_base_url=api_base_url,
            api_version=api_version,
        )
    
        # Making the executive decision that any dictionary
        # data will be sent properly as JSON.
        if data and isinstance(data, dict):
            data = json.dumps(data)
            content_type = "application/json"
    
        response = self._make_request(
            method=method,
            url=url,
            data=data,
            content_type=content_type,
            headers=headers,
            target_object=_target_object,
            timeout=timeout,
            extra_api_info=extra_api_info,
        )
    
        if not 200 <= response.status_code < 300:
>           raise exceptions.from_http_response(response)
E           google.api_core.exceptions.Conflict: 409 POST https://bigquery.googleapis.com/bigquery/v2/projects/apache-beam-testing/datasets/python_write_to_table_17827520083b0f4d/tables?prettyPrint=false: Already Exists: Table apache-beam-testing:python_write_to_table_17827520083b0f4d.python_append_schema_update

../../build/gradleenv/417525525/lib/python3.12/site-packages/google/cloud/_http/__init__.py:494: Conflict

google.api_core.exceptions.Conflict: 409 POST https://bigquery.googleapis.com/bigquery/v2/projects/apache-beam-testing/datasets/python_write_to_table_1782752023303177/tables?prettyPrint=false: Already Exists: Table apache-beam-testing:python_write_to_table_1782752023303177.python_append_schema_update
a = (<apache_beam.io.gcp.bigquery_write_it_test.BigQueryWriteIntegrationTests testMethod=test_big_query_write_temp_table_append_schema_update_2>,)
kw = {}

    @wraps(func)
    def standalone_func(*a, **kw):
>       return func(*(a + p.args), **p.kwargs, **kw)
               ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^

../../build/gradleenv/417525525/lib/python3.12/site-packages/parameterized/parameterized.py:620: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
../../build/gradleenv/417525525/lib/python3.12/site-packages/mock/mock.py:1468: in patched
    return func(*newargs, **newkeywargs)
           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
../../build/gradleenv/417525525/lib/python3.12/site-packages/parameterized/parameterized.py:93: in dummy_func
    return orgfunc(*args, **kwargs)
           ^^^^^^^^^^^^^^^^^^^^^^^^
../../build/gradleenv/417525525/lib/python3.12/site-packages/mock/mock.py:1468: in patched
    return func(*newargs, **newkeywargs)
           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
../../build/gradleenv/417525525/lib/python3.12/site-packages/tenacity/__init__.py:331: in wrapped_f
    return copy(f, *args, **kw)
           ^^^^^^^^^^^^^^^^^^^^
../../build/gradleenv/417525525/lib/python3.12/site-packages/tenacity/__init__.py:470: in __call__
    do = self.iter(retry_state=retry_state)
         ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
../../build/gradleenv/417525525/lib/python3.12/site-packages/tenacity/__init__.py:371: in iter
    result = action(retry_state)
             ^^^^^^^^^^^^^^^^^^^
../../build/gradleenv/417525525/lib/python3.12/site-packages/tenacity/__init__.py:413: in exc_check
    raise retry_exc.reraise()
          ^^^^^^^^^^^^^^^^^^^
../../build/gradleenv/417525525/lib/python3.12/site-packages/tenacity/__init__.py:184: in reraise
    raise self.last_attempt.result()
          ^^^^^^^^^^^^^^^^^^^^^^^^^^
/opt/hostedtoolcache/Python/3.12.13/x64/lib/python3.12/concurrent/futures/_base.py:449: in result
    return self.__get_result()
           ^^^^^^^^^^^^^^^^^^^
/opt/hostedtoolcache/Python/3.12.13/x64/lib/python3.12/concurrent/futures/_base.py:401: in __get_result
    raise self._exception
../../build/gradleenv/417525525/lib/python3.12/site-packages/tenacity/__init__.py:473: in __call__
    result = fn(*args, **kwargs)
             ^^^^^^^^^^^^^^^^^^^
apache_beam/io/gcp/bigquery_write_it_test.py:513: in test_big_query_write_temp_table_append_schema_update
    self.create_table(table_name)
apache_beam/io/gcp/bigquery_write_it_test.py:99: in create_table
    self.bigquery_client.client.create_table(table)
../../build/gradleenv/417525525/lib/python3.12/site-packages/google/cloud/bigquery/client.py:827: in create_table
    api_response = self._call_api(
../../build/gradleenv/417525525/lib/python3.12/site-packages/google/cloud/bigquery/client.py:861: in _call_api
    return call()
           ^^^^^^
../../build/gradleenv/417525525/lib/python3.12/site-packages/google/api_core/retry/retry_unary.py:294: in retry_wrapped_func
    return retry_target(
../../build/gradleenv/417525525/lib/python3.12/site-packages/google/api_core/retry/retry_unary.py:156: in retry_target
    next_sleep = _retry_error_helper(
../../build/gradleenv/417525525/lib/python3.12/site-packages/google/api_core/retry/retry_base.py:216: in _retry_error_helper
    raise final_exc from source_exc
../../build/gradleenv/417525525/lib/python3.12/site-packages/google/api_core/retry/retry_unary.py:147: in retry_target
    result = target()
             ^^^^^^^^
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

self = <google.cloud.bigquery._http.Connection object at 0x7cffbc75c410>
method = 'POST'
path = '/projects/apache-beam-testing/datasets/python_write_to_table_1782752023303177/tables'
query_params = None
data = '{"tableReference": {"projectId": "apache-beam-testing", "datasetId": "python_write_to_table_1782752023303177", "table...LABLE"}, {"name": "date", "type": "DATE", "mode": "NULLABLE"}, {"name": "time", "type": "TIME", "mode": "NULLABLE"}]}}'
content_type = 'application/json', headers = None, api_base_url = None
api_version = None, expect_json = True, _target_object = None, timeout = None
extra_api_info = None

    def api_request(
        self,
        method,
        path,
        query_params=None,
        data=None,
        content_type=None,
        headers=None,
        api_base_url=None,
        api_version=None,
        expect_json=True,
        _target_object=None,
        timeout=_DEFAULT_TIMEOUT,
        extra_api_info=None,
    ):
        """Make a request over the HTTP transport to the API.
    
        You shouldn't need to use this method, but if you plan to
        interact with the API using these primitives, this is the
        correct one to use.
    
        :type method: str
        :param method: The HTTP method name (ie, ``GET``, ``POST``, etc).
                       Required.
    
        :type path: str
        :param path: The path to the resource (ie, ``'/b/bucket-name'``).
                     Required.
    
        :type query_params: dict or list
        :param query_params: A dictionary of keys and values (or list of
                             key-value pairs) to insert into the query
                             string of the URL.
    
        :type data: str
        :param data: The data to send as the body of the request. Default is
                     the empty string.
    
        :type content_type: str
        :param content_type: The proper MIME type of the data provided. Default
                             is None.
    
        :type headers: dict
        :param headers: extra HTTP headers to be sent with the request.
    
        :type api_base_url: str
        :param api_base_url: The base URL for the API endpoint.
                             Typically you won't have to provide this.
                             Default is the standard API base URL.
    
        :type api_version: str
        :param api_version: The version of the API to call.  Typically
                            you shouldn't provide this and instead use
                            the default for the library.  Default is the
                            latest API version supported by
                            google-cloud-python.
    
        :type expect_json: bool
        :param expect_json: If True, this method will try to parse the
                            response as JSON and raise an exception if
                            that cannot be done.  Default is True.
    
        :type _target_object: :class:`object`
        :param _target_object:
            (Optional) Protected argument to be used by library callers. This
            can allow custom behavior, for example, to defer an HTTP request
            and complete initialization of the object at a later time.
    
        :type timeout: float or tuple
        :param timeout: (optional) The amount of time, in seconds, to wait
            for the server response.
    
            Can also be passed as a tuple (connect_timeout, read_timeout).
            See :meth:`requests.Session.request` documentation for details.
    
        :type extra_api_info: string
        :param extra_api_info: (optional) Extra api info to be appended to
            the X-Goog-API-Client header
    
        :raises ~google.cloud.exceptions.GoogleCloudError: if the response code
            is not 200 OK.
        :raises ValueError: if the response content type is not JSON.
        :rtype: dict or str
        :returns: The API response payload, either as a raw string or
                  a dictionary if the response is valid JSON.
        """
        url = self.build_api_url(
            path=path,
            query_params=query_params,
            api_base_url=api_base_url,
            api_version=api_version,
        )
    
        # Making the executive decision that any dictionary
        # data will be sent properly as JSON.
        if data and isinstance(data, dict):
            data = json.dumps(data)
            content_type = "application/json"
    
        response = self._make_request(
            method=method,
            url=url,
            data=data,
            content_type=content_type,
            headers=headers,
            target_object=_target_object,
            timeout=timeout,
            extra_api_info=extra_api_info,
        )
    
        if not 200 <= response.status_code < 300:
>           raise exceptions.from_http_response(response)
E           google.api_core.exceptions.Conflict: 409 POST https://bigquery.googleapis.com/bigquery/v2/projects/apache-beam-testing/datasets/python_write_to_table_1782752023303177/tables?prettyPrint=false: Already Exists: Table apache-beam-testing:python_write_to_table_1782752023303177.python_append_schema_update

../../build/gradleenv/417525525/lib/python3.12/site-packages/google/cloud/_http/__init__.py:494: Conflict

google.api_core.exceptions.Conflict: 409 POST https://bigquery.googleapis.com/bigquery/v2/projects/apache-beam-testing/datasets/python_write_to_table_1782752030fa67c7/tables?prettyPrint=false: Already Exists: Table apache-beam-testing:python_write_to_table_1782752030fa67c7.python_append_schema_update
a = (<apache_beam.io.gcp.bigquery_write_it_test.BigQueryWriteIntegrationTests testMethod=test_big_query_write_temp_table_append_schema_update_0>,)
kw = {}

    @wraps(func)
    def standalone_func(*a, **kw):
>       return func(*(a + p.args), **p.kwargs, **kw)
               ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^

../../build/gradleenv/417525525/lib/python3.12/site-packages/parameterized/parameterized.py:620: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
../../build/gradleenv/417525525/lib/python3.12/site-packages/mock/mock.py:1468: in patched
    return func(*newargs, **newkeywargs)
           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
../../build/gradleenv/417525525/lib/python3.12/site-packages/parameterized/parameterized.py:93: in dummy_func
    return orgfunc(*args, **kwargs)
           ^^^^^^^^^^^^^^^^^^^^^^^^
../../build/gradleenv/417525525/lib/python3.12/site-packages/mock/mock.py:1468: in patched
    return func(*newargs, **newkeywargs)
           ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
../../build/gradleenv/417525525/lib/python3.12/site-packages/tenacity/__init__.py:331: in wrapped_f
    return copy(f, *args, **kw)
           ^^^^^^^^^^^^^^^^^^^^
../../build/gradleenv/417525525/lib/python3.12/site-packages/tenacity/__init__.py:470: in __call__
    do = self.iter(retry_state=retry_state)
         ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
../../build/gradleenv/417525525/lib/python3.12/site-packages/tenacity/__init__.py:371: in iter
    result = action(retry_state)
             ^^^^^^^^^^^^^^^^^^^
../../build/gradleenv/417525525/lib/python3.12/site-packages/tenacity/__init__.py:413: in exc_check
    raise retry_exc.reraise()
          ^^^^^^^^^^^^^^^^^^^
../../build/gradleenv/417525525/lib/python3.12/site-packages/tenacity/__init__.py:184: in reraise
    raise self.last_attempt.result()
          ^^^^^^^^^^^^^^^^^^^^^^^^^^
/opt/hostedtoolcache/Python/3.12.13/x64/lib/python3.12/concurrent/futures/_base.py:449: in result
    return self.__get_result()
           ^^^^^^^^^^^^^^^^^^^
/opt/hostedtoolcache/Python/3.12.13/x64/lib/python3.12/concurrent/futures/_base.py:401: in __get_result
    raise self._exception
../../build/gradleenv/417525525/lib/python3.12/site-packages/tenacity/__init__.py:473: in __call__
    result = fn(*args, **kwargs)
             ^^^^^^^^^^^^^^^^^^^
apache_beam/io/gcp/bigquery_write_it_test.py:513: in test_big_query_write_temp_table_append_schema_update
    self.create_table(table_name)
apache_beam/io/gcp/bigquery_write_it_test.py:99: in create_table
    self.bigquery_client.client.create_table(table)
../../build/gradleenv/417525525/lib/python3.12/site-packages/google/cloud/bigquery/client.py:827: in create_table
    api_response = self._call_api(
../../build/gradleenv/417525525/lib/python3.12/site-packages/google/cloud/bigquery/client.py:861: in _call_api
    return call()
           ^^^^^^
../../build/gradleenv/417525525/lib/python3.12/site-packages/google/api_core/retry/retry_unary.py:294: in retry_wrapped_func
    return retry_target(
../../build/gradleenv/417525525/lib/python3.12/site-packages/google/api_core/retry/retry_unary.py:156: in retry_target
    next_sleep = _retry_error_helper(
../../build/gradleenv/417525525/lib/python3.12/site-packages/google/api_core/retry/retry_base.py:216: in _retry_error_helper
    raise final_exc from source_exc
../../build/gradleenv/417525525/lib/python3.12/site-packages/google/api_core/retry/retry_unary.py:147: in retry_target
    result = target()
             ^^^^^^^^
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

self = <google.cloud.bigquery._http.Connection object at 0x7bf99c00f6b0>
method = 'POST'
path = '/projects/apache-beam-testing/datasets/python_write_to_table_1782752030fa67c7/tables'
query_params = None
data = '{"tableReference": {"projectId": "apache-beam-testing", "datasetId": "python_write_to_table_1782752030fa67c7", "table...LABLE"}, {"name": "date", "type": "DATE", "mode": "NULLABLE"}, {"name": "time", "type": "TIME", "mode": "NULLABLE"}]}}'
content_type = 'application/json', headers = None, api_base_url = None
api_version = None, expect_json = True, _target_object = None, timeout = None
extra_api_info = None

    def api_request(
        self,
        method,
        path,
        query_params=None,
        data=None,
        content_type=None,
        headers=None,
        api_base_url=None,
        api_version=None,
        expect_json=True,
        _target_object=None,
        timeout=_DEFAULT_TIMEOUT,
        extra_api_info=None,
    ):
        """Make a request over the HTTP transport to the API.
    
        You shouldn't need to use this method, but if you plan to
        interact with the API using these primitives, this is the
        correct one to use.
    
        :type method: str
        :param method: The HTTP method name (ie, ``GET``, ``POST``, etc).
                       Required.
    
        :type path: str
        :param path: The path to the resource (ie, ``'/b/bucket-name'``).
                     Required.
    
        :type query_params: dict or list
        :param query_params: A dictionary of keys and values (or list of
                             key-value pairs) to insert into the query
                             string of the URL.
    
        :type data: str
        :param data: The data to send as the body of the request. Default is
                     the empty string.
    
        :type content_type: str
        :param content_type: The proper MIME type of the data provided. Default
                             is None.
    
        :type headers: dict
        :param headers: extra HTTP headers to be sent with the request.
    
        :type api_base_url: str
        :param api_base_url: The base URL for the API endpoint.
                             Typically you won't have to provide this.
                             Default is the standard API base URL.
    
        :type api_version: str
        :param api_version: The version of the API to call.  Typically
                            you shouldn't provide this and instead use
                            the default for the library.  Default is the
                            latest API version supported by
                            google-cloud-python.
    
        :type expect_json: bool
        :param expect_json: If True, this method will try to parse the
                            response as JSON and raise an exception if
                            that cannot be done.  Default is True.
    
        :type _target_object: :class:`object`
        :param _target_object:
            (Optional) Protected argument to be used by library callers. This
            can allow custom behavior, for example, to defer an HTTP request
            and complete initialization of the object at a later time.
    
        :type timeout: float or tuple
        :param timeout: (optional) The amount of time, in seconds, to wait
            for the server response.
    
            Can also be passed as a tuple (connect_timeout, read_timeout).
            See :meth:`requests.Session.request` documentation for details.
    
        :type extra_api_info: string
        :param extra_api_info: (optional) Extra api info to be appended to
            the X-Goog-API-Client header
    
        :raises ~google.cloud.exceptions.GoogleCloudError: if the response code
            is not 200 OK.
        :raises ValueError: if the response content type is not JSON.
        :rtype: dict or str
        :returns: The API response payload, either as a raw string or
                  a dictionary if the response is valid JSON.
        """
        url = self.build_api_url(
            path=path,
            query_params=query_params,
            api_base_url=api_base_url,
            api_version=api_version,
        )
    
        # Making the executive decision that any dictionary
        # data will be sent properly as JSON.
        if data and isinstance(data, dict):
            data = json.dumps(data)
            content_type = "application/json"
    
        response = self._make_request(
            method=method,
            url=url,
            data=data,
            content_type=content_type,
            headers=headers,
            target_object=_target_object,
            timeout=timeout,
            extra_api_info=extra_api_info,
        )
    
        if not 200 <= response.status_code < 300:
>           raise exceptions.from_http_response(response)
E           google.api_core.exceptions.Conflict: 409 POST https://bigquery.googleapis.com/bigquery/v2/projects/apache-beam-testing/datasets/python_write_to_table_1782752030fa67c7/tables?prettyPrint=false: Already Exists: Table apache-beam-testing:python_write_to_table_1782752030fa67c7.python_append_schema_update

../../build/gradleenv/417525525/lib/python3.12/site-packages/google/cloud/_http/__init__.py:494: Conflict

AttributeError: 'TableReference' object has no attribute 'datasetId'. Did you mean: 'dataset_id'?
self = <apache_beam.io.gcp.bigquery_test.BigQueryStreamingInsertTransformIntegrationTests testMethod=test_value_provider_transform>

    @pytest.mark.it_postcommit
    def test_value_provider_transform(self):
      output_table_1 = '%s%s' % (self.output_table, 1)
      output_table_2 = '%s%s' % (self.output_table, 2)
      schema = {
          'fields': [{
              'name': 'name', 'type': 'STRING', 'mode': 'NULLABLE'
          }, {
              'name': 'language', 'type': 'STRING', 'mode': 'NULLABLE'
          }]
      }
    
      additional_bq_parameters = {
          'timePartitioning': {
              'type': 'DAY'
          },
          'clustering': {
              'fields': ['language']
          }
      }
    
      table_ref = bigquery_tools.parse_table_reference(output_table_1)
      table_ref2 = bigquery_tools.parse_table_reference(output_table_2)
    
      pipeline_verifiers = [
          BigQueryTableMatcher(
              project=self.project,
>             dataset=table_ref.datasetId,
                      ^^^^^^^^^^^^^^^^^^^
              table=table_ref.tableId,
              expected_properties=additional_bq_parameters),
          BigQueryTableMatcher(
              project=self.project,
              dataset=table_ref2.datasetId,
              table=table_ref2.tableId,
              expected_properties=additional_bq_parameters),
          BigqueryFullResultMatcher(
              project=self.project,
              query="SELECT name, language FROM %s" % output_table_1,
              data=[(d['name'], d['language']) for d in _ELEMENTS
                    if 'language' in d]),
          BigqueryFullResultMatcher(
              project=self.project,
              query="SELECT name, language FROM %s" % output_table_2,
              data=[(d['name'], d['language']) for d in _ELEMENTS
                    if 'language' in d])
      ]
E     AttributeError: 'TableReference' object has no attribute 'datasetId'. Did you mean: 'dataset_id'?

apache_beam/io/gcp/bigquery_test.py:2417: AttributeError

ImportError: cannot import name 'TableSchema' from 'google.cloud.bigquery' (/runner/_work/beam/beam/build/gradleenv/2050596100/lib/python3.12/site-packages/google/cloud/bigquery/__init__.py)
self = <apache_beam.io.gcp.bigquery_json_it_test.BigQueryJsonIT testMethod=test_file_loads_write>

    @pytest.mark.it_postcommit
    def test_file_loads_write(self):
      extra_opts = {
          'output': f"{PROJECT}:{DATASET_ID}.{FILE_LOAD_TABLE}",
          'write_method': "FILE_LOADS",
          "unescape": "True"
      }
      options = self.test_pipeline.get_full_options_as_args(**extra_opts)
>     self.run_test_write(options)

apache_beam/io/gcp/bigquery_json_it_test.py:243: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
apache_beam/io/gcp/bigquery_json_it_test.py:78: in run_test_write
    json_table_schema = self.generate_schema()
                        ^^^^^^^^^^^^^^^^^^^^^^
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

self = <apache_beam.io.gcp.bigquery_json_it_test.BigQueryJsonIT testMethod=test_file_loads_write>

    def generate_schema(self):
      from google.cloud.bigquery import SchemaField
>     from google.cloud.bigquery import TableSchema
E     ImportError: cannot import name 'TableSchema' from 'google.cloud.bigquery' (/runner/_work/beam/beam/build/gradleenv/2050596100/lib/python3.12/site-packages/google/cloud/bigquery/__init__.py)

apache_beam/io/gcp/bigquery_json_it_test.py:248: ImportError

ImportError: cannot import name 'TableSchema' from 'google.cloud.bigquery' (/runner/_work/beam/beam/build/gradleenv/2050596100/lib/python3.12/site-packages/google/cloud/bigquery/__init__.py)
self = <apache_beam.io.gcp.bigquery_json_it_test.BigQueryJsonIT testMethod=test_streaming_inserts>

    @pytest.mark.it_postcommit
    def test_streaming_inserts(self):
      extra_opts = {
          'output': f"{PROJECT}:{DATASET_ID}.{STREAMING_TEST_TABLE}",
          'write_method': "STREAMING_INSERTS"
      }
      options = self.test_pipeline.get_full_options_as_args(**extra_opts)
    
>     self.run_test_write(options)

apache_beam/io/gcp/bigquery_json_it_test.py:233: 
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 
apache_beam/io/gcp/bigquery_json_it_test.py:78: in run_test_write
    json_table_schema = self.generate_schema()
                        ^^^^^^^^^^^^^^^^^^^^^^
_ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ _ 

self = <apache_beam.io.gcp.bigquery_json_it_test.BigQueryJsonIT testMethod=test_streaming_inserts>

    def generate_schema(self):
      from google.cloud.bigquery import SchemaField
>     from google.cloud.bigquery import TableSchema
E     ImportError: cannot import name 'TableSchema' from 'google.cloud.bigquery' (/runner/_work/beam/beam/build/gradleenv/2050596100/lib/python3.12/site-packages/google/cloud/bigquery/__init__.py)

apache_beam/io/gcp/bigquery_json_it_test.py:248: ImportError