Update pkg/transport/dispatcher/dispatcher_e2e_test.go

Co-authored-by: coderabbitai[bot] <136622811+coderabbitai[bot]@users.noreply.github.com>
bacalhau-project · Nov 26, 2024 · e2eeaf5 · e2eeaf5
1 parent c3d5c67
commit e2eeaf5
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/pkg/transport/dispatcher/dispatcher_e2e_test.go b/pkg/transport/dispatcher/dispatcher_e2e_test.go
@@ -258,7 +258,7 @@ func (s *DispatcherE2ETestSuite) storeEvents(count int) {
 }
 
 func (s *DispatcherE2ETestSuite) verifyMsg(msg *envelope.Message, i int) {
-	payload, ok := msg.GetPayload("")
+	payload, ok := msg.GetPayload("string")
 	s.Require().True(ok, "payload missing or not a string")
 	s.Contains(payload, fmt.Sprintf("event-%d", i))
 	s.Require().Equal(fmt.Sprintf("%d", i), msg.Metadata.Get(dispatcher.KeySeqNum))