pir_pipeline.query.core.write_to_s3

pir_pipeline.query.core.write_to_s3(client, records, **kwargs)