From 81b0295842c49298293f3daffb0ebc93c8714b1a Mon Sep 17 00:00:00 2001 From: Vladislav Sukhin Date: Mon, 2 Dec 2024 15:13:12 +0300 Subject: [PATCH] fix: rename url Signed-off-by: Vladislav Sukhin --- pkg/api/v1/client/testworkflow.go | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/pkg/api/v1/client/testworkflow.go b/pkg/api/v1/client/testworkflow.go index 77c4299ed7..d683374809 100644 --- a/pkg/api/v1/client/testworkflow.go +++ b/pkg/api/v1/client/testworkflow.go @@ -149,7 +149,7 @@ func (c TestWorkflowClient) GetTestWorkflowExecutionNotifications(id string) (no // GetTestWorkflowExecutionServiceNotifications returns events stream from job pods, based on job pods logs func (c TestWorkflowClient) GetTestWorkflowExecutionServiceNotifications(id, serviceName string, serviceIndex int) (notifications chan testkube.TestWorkflowExecutionNotification, err error) { notifications = make(chan testkube.TestWorkflowExecutionNotification) - uri := c.testWorkflowTransport.GetURI("/test-workflow-executions/%s/notifications/%s/%d", id, serviceName, serviceIndex) + uri := c.testWorkflowTransport.GetURI("/test-workflow-executions/%s/notifications/services/%s/%d", id, serviceName, serviceIndex) err = c.testWorkflowTransport.GetTestWorkflowExecutionNotifications(uri, notifications) return notifications, err } @@ -157,7 +157,7 @@ func (c TestWorkflowClient) GetTestWorkflowExecutionServiceNotifications(id, ser // GetTestWorkflowExecutionParallelStepNotifications returns events stream from job pods, based on job pods logs func (c TestWorkflowClient) GetTestWorkflowExecutionParallelStepNotifications(id, parallelStepName string, parallelStepIndex int) (notifications chan testkube.TestWorkflowExecutionNotification, err error) { notifications = make(chan testkube.TestWorkflowExecutionNotification) - uri := c.testWorkflowTransport.GetURI("/test-workflow-executions/%s/notifications/%s/%d", id, parallelStepName, parallelStepIndex) + uri := c.testWorkflowTransport.GetURI("/test-workflow-executions/%s/notifications/parallel-steps/%s/%d", id, parallelStepName, parallelStepIndex) err = c.testWorkflowTransport.GetTestWorkflowExecutionNotifications(uri, notifications) return notifications, err }