fixing test case

Signed-off-by: veds-g <[email protected]>
numaproj · Jan 25, 2023 · c5aee7c · c5aee7c
1 parent 53cbad0
commit c5aee7c
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/pkg/reduce/data_forward_test.go b/pkg/reduce/data_forward_test.go
@@ -95,6 +95,10 @@ func (e *EventTypeWMProgressor) GetHeadWatermark() processor.Watermark {
 	return processor.Watermark{}
 }
 
+func (e *EventTypeWMProgressor) GetPodWatermarks() []processor.Watermark {
+	return []processor.Watermark{}
+}
+
 // PayloadForTest is a dummy payload for testing.
 type PayloadForTest struct {
 	Key   string