[beam] branch master updated: fix reference to StorageWriteToBigQuery (#26487)

[yh...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

yhu pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git


The following commit(s) were added to refs/heads/master by this push:
     new 94601a56d67 fix reference to StorageWriteToBigQuery (#26487)
94601a56d67 is described below

commit 94601a56d67de5e0cfc7715931bfbed423c1f88c
Author: Ahmed Abualsaud <65...@users.noreply.github.com>
AuthorDate: Wed May 3 03:34:30 2023 +0300

    fix reference to StorageWriteToBigQuery (#26487)
---
 sdks/python/apache_beam/io/external/xlang_bigqueryio_it_test.py | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/sdks/python/apache_beam/io/external/xlang_bigqueryio_it_test.py b/sdks/python/apache_beam/io/external/xlang_bigqueryio_it_test.py
index 48f4ab02b0c..6a14cdecf42 100644
--- a/sdks/python/apache_beam/io/external/xlang_bigqueryio_it_test.py
+++ b/sdks/python/apache_beam/io/external/xlang_bigqueryio_it_test.py
@@ -30,6 +30,7 @@ import pytest
 from hamcrest.core import assert_that as hamcrest_assert
 
 import apache_beam as beam
+from apache_beam.io.gcp.bigquery import StorageWriteToBigQuery
 from apache_beam.io.gcp.bigquery_tools import BigQueryWrapper
 from apache_beam.io.gcp.internal.clients import bigquery
 from apache_beam.io.gcp.tests.bigquery_matcher import BigqueryFullResultMatcher
@@ -229,7 +230,7 @@ class BigQueryXlangStorageWriteIT(unittest.TestCase):
       _ = (
           p
           | beam.Create(row_elements)
-          | beam.io.StorageWriteToBigQuery(
+          | StorageWriteToBigQuery(
               table=table_id, expansion_service=self.expansion_service))
     hamcrest_assert(p, bq_matcher)