add logs when no records to push

PeerDB-io · Dec 17, 2023 · 9611710 · 9611710
1 parent 533d6c9
commit 9611710
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/flow/connectors/bigquery/qrep_avro_sync.go b/flow/connectors/bigquery/qrep_avro_sync.go
@@ -365,6 +365,9 @@ func (s *QRepAvroSyncMethod) writeToStage(
 	defer avroFile.Cleanup()
 
 	if avroFile.NumRecords == 0 {
+		log.WithFields(log.Fields{
+			"batchOrPartitionID": syncID,
+		}).Infof("no records to write to file %s", avroFile.FilePath)
 		return 0, nil
 	}
 	log.WithFields(log.Fields{