From 572375c7bb1955b653baa7d6ff9dc6dbf5bc4f20 Mon Sep 17 00:00:00 2001 From: jrmccluskey Date: Thu, 28 May 2026 11:33:12 -0400 Subject: [PATCH 1/2] Re-enable call-args check in yaml_io.py --- sdks/python/apache_beam/yaml/yaml_io.py | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/sdks/python/apache_beam/yaml/yaml_io.py b/sdks/python/apache_beam/yaml/yaml_io.py index f59e730ac815..a31b13f1a794 100644 --- a/sdks/python/apache_beam/yaml/yaml_io.py +++ b/sdks/python/apache_beam/yaml/yaml_io.py @@ -246,11 +246,10 @@ def _validate_schema(): _validate_schema() beam_schema = avroio.avro_schema_to_beam_schema(schema) covert_to_row = avroio.avro_dict_to_beam_row(schema, beam_schema) - # pylint: disable=line-too-long return ( beam_schema, lambda record: covert_to_row( - fastavro.schemaless_reader(io.BytesIO(record), schema))) # type: ignore[call-arg] + fastavro.schemaless_reader(io.BytesIO(record), schema))) elif format == 'PROTO': _validate_schema() beam_schema = json_utils.json_schema_to_beam_schema(schema) From 29e3a21d4e76641e1e1248f3dd984192393b4a16 Mon Sep 17 00:00:00 2001 From: jrmccluskey Date: Thu, 28 May 2026 11:53:11 -0400 Subject: [PATCH 2/2] yapf --- sdks/python/apache_beam/yaml/yaml_io.py | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/sdks/python/apache_beam/yaml/yaml_io.py b/sdks/python/apache_beam/yaml/yaml_io.py index a31b13f1a794..e659fca06a98 100644 --- a/sdks/python/apache_beam/yaml/yaml_io.py +++ b/sdks/python/apache_beam/yaml/yaml_io.py @@ -247,8 +247,7 @@ def _validate_schema(): beam_schema = avroio.avro_schema_to_beam_schema(schema) covert_to_row = avroio.avro_dict_to_beam_row(schema, beam_schema) return ( - beam_schema, - lambda record: covert_to_row( + beam_schema, lambda record: covert_to_row( fastavro.schemaless_reader(io.BytesIO(record), schema))) elif format == 'PROTO': _validate_schema()