fix test failures

PeerDB-io · Oct 30, 2023 · f65b582 · f65b582
1 parent e515a5c
commit f65b582
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 2 deletions.
diff --git a/flow/connectors/bigquery/bigquery.go b/flow/connectors/bigquery/bigquery.go
@@ -835,7 +835,6 @@ 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 {

diff --git a/flow/connectors/s3/s3.go b/flow/connectors/s3/s3.go
@@ -155,7 +155,6 @@ func (c *S3Connector) SyncRecords(req *model.SyncRecordsRequest) (*model.SyncRes
 	partition := &protos.QRepPartition{
 		PartitionId: fmt.Sprint(syncBatchID),
 	}
-	close(recordStream.Records)
 	numRecords, err := c.SyncQRepRecords(qrepConfig, partition, recordStream)
 	if err != nil {
 		return nil, err