This is an automated email from the ASF dual-hosted git repository.
jrmccluskey 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 44a2ff6146c Re-enable call-args check in yaml_io.py (#38730)
44a2ff6146c is described below
commit 44a2ff6146c6f4b0ca99eeedb15439967e574ee8
Author: Jack McCluskey <[email protected]>
AuthorDate: Fri May 29 15:08:05 2026 -0400
Re-enable call-args check in yaml_io.py (#38730)
* Re-enable call-args check in yaml_io.py
* yapf
---
sdks/python/apache_beam/yaml/yaml_io.py | 6 ++----
1 file changed, 2 insertions(+), 4 deletions(-)
diff --git a/sdks/python/apache_beam/yaml/yaml_io.py
b/sdks/python/apache_beam/yaml/yaml_io.py
index eaa0d431750..989661a6eae 100644
--- a/sdks/python/apache_beam/yaml/yaml_io.py
+++ b/sdks/python/apache_beam/yaml/yaml_io.py
@@ -247,11 +247,9 @@ def _create_parser(
_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]
+ beam_schema, lambda record: covert_to_row(
+ fastavro.schemaless_reader(io.BytesIO(record), schema)))
elif format == 'PROTO':
_validate_schema()
beam_schema = json_utils.json_schema_to_beam_schema(schema)
