diff --git a/README.md b/README.md
index 3640489..df71628 100644
--- a/README.md
+++ b/README.md
@@ -56,7 +56,7 @@ import { ParquetWriter, ParquetSchema } from "@dsnp/parquetjs";
 
 const [parquetSchema, writerOptions] = parquet.fromDSNPSchema(descriptorForAnnouncementType(AnnouncementType.Broadcast).parquetSchema);
 const writer = await ParquetWriter.openFile(new ParquetSchema(parquetSchema), "./file.parquet", writerOptions);
-writer.appendRow({
+await writer.appendRow({
   announcementType: AnnouncementType.Broadcast,
   contentHash: "bciqdnu347gcfmxzbkhgoubiobphm6readngitfywktdtbdocgogop2q",
   fromId: 78187493520,
diff --git a/parquet.spec.ts b/parquet.spec.ts
index 48e0314..2e95b81 100644
--- a/parquet.spec.ts
+++ b/parquet.spec.ts
@@ -21,7 +21,7 @@ describe("DSNP Schema Conversion Test File", () => {
 
   beforeAll(async () => {
     const writer = await ParquetWriter.openFile(new ParquetSchema(parquetSchema), path, writerOptions);
-    writer.appendRow(row1);
+    await writer.appendRow(row1);
     await writer.close();
 
     reader = await ParquetReader.openFile(path);