This is an automated email from the ASF dual-hosted git repository.
pabloem 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 9e96ddd4c38 fix test decotrator typo
new 0b86cd6220c Merge pull request #17542 from [BEAM-14273] typo fix for
BigQueryIO JSON test (python)
9e96ddd4c38 is described below
commit 9e96ddd4c38bf37ce0f1c43573ca761de89a9c64
Author: ahmedabu98 <[email protected]>
AuthorDate: Wed May 4 16:17:16 2022 +0000
fix test decotrator typo
---
sdks/python/apache_beam/io/gcp/bigquery_json_it_test.py | 10 +++++-----
1 file changed, 5 insertions(+), 5 deletions(-)
diff --git a/sdks/python/apache_beam/io/gcp/bigquery_json_it_test.py
b/sdks/python/apache_beam/io/gcp/bigquery_json_it_test.py
index 6562a643343..13bf63a46a1 100644
--- a/sdks/python/apache_beam/io/gcp/bigquery_json_it_test.py
+++ b/sdks/python/apache_beam/io/gcp/bigquery_json_it_test.py
@@ -149,7 +149,7 @@ class BigQueryJsonIT(unittest.TestCase):
method=method,
) | 'Validate rows' >> beam.ParDo(CompareJson())
- @pytest.mark.it_postcomit
+ @pytest.mark.it_postcommit
def test_direct_read(self):
extra_opts = {
'read_method': "DIRECT_READ",
@@ -159,7 +159,7 @@ class BigQueryJsonIT(unittest.TestCase):
self.read_and_validate_rows(options)
- @pytest.mark.it_postcomit
+ @pytest.mark.it_postcommit
def test_export_read(self):
extra_opts = {
'read_method': "EXPORT",
@@ -169,7 +169,7 @@ class BigQueryJsonIT(unittest.TestCase):
self.read_and_validate_rows(options)
- @pytest.mark.it_postcomit
+ @pytest.mark.it_postcommit
def test_query_read(self):
extra_opts = {
'query': "SELECT "
@@ -184,7 +184,7 @@ class BigQueryJsonIT(unittest.TestCase):
self.read_and_validate_rows(options)
- @pytest.mark.it_postcomit
+ @pytest.mark.it_postcommit
def test_streaming_inserts(self):
extra_opts = {
'output': f"{PROJECT}:{DATASET_ID}.{STREAMING_TEST_TABLE}",
@@ -194,7 +194,7 @@ class BigQueryJsonIT(unittest.TestCase):
self.run_test_write(options)
- @pytest.mark.it_postcomit
+ @pytest.mark.it_postcommit
def test_file_loads_write(self):
extra_opts = {
'output': f"{PROJECT}:{DATASET_ID}.{STREAMING_TEST_TABLE}",