diff --git a/pkg/agent/testworkflows.go b/pkg/agent/testworkflows.go
index c11cdeeb7a..4e13ee0178 100644
--- a/pkg/agent/testworkflows.go
+++ b/pkg/agent/testworkflows.go
@@ -397,7 +397,7 @@ func (ag *Agent) executeWorkflowParallelStepNotificationsRequest(ctx context.Con
 	)
 
 	if err != nil {
-		message := fmt.Sprintf("cannot get service pod logs: %s", err.Error())
+		message := fmt.Sprintf("cannot get parallel step pod logs: %s", err.Error())
 		ag.testWorkflowParallelStepNotificationsResponseBuffer <- &cloud.TestWorkflowParallelStepNotificationsResponse{
 			StreamId: req.StreamId,
 			SeqNo:    0,