This is an automated email from the ASF dual-hosted git repository.
shunping 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 a74f328f26e [yaml] - fix post commit yaml test (#40633)
a74f328f26e is described below
commit a74f328f26eb748ab47f2d4647c28667447cd551
Author: Derrick Williams <[email protected]>
AuthorDate: Fri Oct 16 15:50:19 2026 -0400
[yaml] - fix post commit yaml test (#40633)
* [yaml] - fix post commit yaml test
* trigger postcommit
---
.github/trigger_files/beam_PostCommit_Yaml_Xlang_Direct.json | 2 +-
.github/trigger_files/beam_PreCommit_Yaml_Xlang_Direct.json | 2 +-
.../yaml/extended_tests/e2e/gcs_avro_to_cloud_bigtable.yaml | 10 +++++-----
3 files changed, 7 insertions(+), 7 deletions(-)
diff --git a/.github/trigger_files/beam_PostCommit_Yaml_Xlang_Direct.json
b/.github/trigger_files/beam_PostCommit_Yaml_Xlang_Direct.json
index a975cd1cd10..541dc4ea8e8 100644
--- a/.github/trigger_files/beam_PostCommit_Yaml_Xlang_Direct.json
+++ b/.github/trigger_files/beam_PostCommit_Yaml_Xlang_Direct.json
@@ -1,4 +1,4 @@
{
"comment": "Modify this file in a trivial way to cause this test suite to
run",
- "revision": 1
+ "revision": 2
}
diff --git a/.github/trigger_files/beam_PreCommit_Yaml_Xlang_Direct.json
b/.github/trigger_files/beam_PreCommit_Yaml_Xlang_Direct.json
index 8c604b0a135..840d064bdbb 100644
--- a/.github/trigger_files/beam_PreCommit_Yaml_Xlang_Direct.json
+++ b/.github/trigger_files/beam_PreCommit_Yaml_Xlang_Direct.json
@@ -1,4 +1,4 @@
{
"comment": "Modify this file in a trivial way to cause this test suite to
run",
- "revision": 2
+ "revision": 3
}
diff --git
a/sdks/python/apache_beam/yaml/extended_tests/e2e/gcs_avro_to_cloud_bigtable.yaml
b/sdks/python/apache_beam/yaml/extended_tests/e2e/gcs_avro_to_cloud_bigtable.yaml
index e492e697af3..86c1a466061 100644
---
a/sdks/python/apache_beam/yaml/extended_tests/e2e/gcs_avro_to_cloud_bigtable.yaml
+++
b/sdks/python/apache_beam/yaml/extended_tests/e2e/gcs_avro_to_cloud_bigtable.yaml
@@ -64,7 +64,7 @@ pipelines:
key:
callable: |
def convert_to_bytes(row):
- return bytes(row.key, 'utf-8') if "key" in row._fields
else None
+ return bytes(row.key, 'utf-8') if hasattr(row, "key") else
None
type:
type
family_name:
@@ -72,11 +72,11 @@ pipelines:
column_qualifier:
callable: |
def convert_to_bytes(row):
- return bytes(row.column_qualifier, 'utf-8') if
'column_qualifier' in row._fields else None
+ return bytes(row.column_qualifier, 'utf-8') if
hasattr(row, 'column_qualifier') else None
value:
callable: |
def convert_to_bytes(row):
- return bytes(row.value, 'utf-8') if 'value' in row._fields
else None
+ return bytes(row.value, 'utf-8') if hasattr(row, 'value')
else None
timestamp_micros:
timestamp_micros
- type: WriteToBigTable
@@ -102,13 +102,13 @@ pipelines:
key:
callable: |
def convert_to_string(row):
- return row.key.decode("utf-8") if "key" in row._fields
else None
+ return row.key.decode("utf-8") if hasattr(row, "key") else
None
family_name:
family_name
column_qualifier:
callable: |
def convert_to_string(row):
- return row.column_qualifier.decode("utf-8") if
"column_qualifier" in row._fields else None
+ return row.column_qualifier.decode("utf-8") if
hasattr(row, "column_qualifier") else None
cells:
callable: |
def convert_to_string(row):
