close channel for BQ avro writer

PeerDB-io · Oct 30, 2023 · 8a31900 · 8a31900
1 parent ecea49b
commit 8a31900
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/flow/connectors/bigquery/bigquery.go b/flow/connectors/bigquery/bigquery.go
@@ -831,6 +831,7 @@ func (c *BigQueryConnector) syncRecordsViaAvro(
 		}
 	}
 
+	close(recordStream.Records)
 	avroSync := NewQRepAvroSyncMethod(c, req.StagingPath)
 	rawTableMetadata, err := c.client.Dataset(c.datasetID).Table(rawTableName).Metadata(c.ctx)
 	if err != nil {