diff --git a/sdks/python/apache_beam/yaml/yaml_io.py b/sdks/python/apache_beam/yaml/yaml_io.py
index f59e730ac815..e659fca06a98 100644
--- a/sdks/python/apache_beam/yaml/yaml_io.py
+++ b/sdks/python/apache_beam/yaml/yaml_io.py
@@ -246,11 +246,9 @@ 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]
+        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)