explicit arg names

sdks/python/apache_beam/yaml/yaml_io.py

@@ -77,8 +77,8 @@ def write_to_text(pcoll, path: str):
   """
   try:
     field_names = [
-        name for name,
-        _ in schemas.named_fields_from_element_type(pcoll.element_type)
+        name for name, _ in schemas.named_fields_from_element_type(
+            pcoll.element_type)
     ]
   except Exception as exn:
     raise ValueError(
@@ -167,7 +167,9 @@ def write_to_bigquery(
         described at https://beam.apache.org/documentation/sdks/yaml-errors/
         Otherwise permanently failing records will cause pipeline failure.
   """
+
   class WriteToBigQueryHandlingErrors(beam.PTransform):
+
     def default_label(self):
       return 'WriteToBigQuery'
 
@@ -236,9 +238,9 @@ 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(
-            fastavro.schemaless_reader(io.BytesIO(record), schema)))
+        beam_schema, lambda record: covert_to_row(
+            fastavro.schemaless_reader(
+                fo=io.BytesIO(record), writer_schema=schema)))
   else:
     raise ValueError(f'Unknown format: {format}')