revert peer flow test, fix cdc

PeerDB-io · Feb 7, 2024 · 7ec976b · 7ec976b
1 parent 75c82d2
commit 7ec976b
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/flow/model/model.go b/flow/model/model.go
@@ -215,6 +215,11 @@ func (r *RecordItems) toMap(hstoreAsJSON bool) (map[string]interface{}, error) {
 			if !ok {
 				return nil, errors.New("expected *big.Rat value")
 			}
+
+			if bigRat == nil {
+				jsonStruct[col] = nil
+				continue
+			}
 			jsonStruct[col] = bigRat.FloatString(numeric.PeerDBNumericScale)
 		case qvalue.QValueKindFloat64:
 			floatVal, ok := v.Value.(float64)