fix: lint

Signed-off-by: Vladislav Sukhin <[email protected]>

pkg/agent/agent.go

@@ -111,11 +111,14 @@ func NewAgent(logger *zap.SugaredLogger,
 		testWorkflowNotificationsRequestBuffer:  make(chan *cloud.TestWorkflowNotificationsRequest, bufferSizePerWorker*proContext.WorkflowNotificationsWorkerCount),
 		testWorkflowNotificationsResponseBuffer: make(chan *cloud.TestWorkflowNotificationsResponse, bufferSizePerWorker*proContext.WorkflowNotificationsWorkerCount),
 		testWorkflowNotificationsFunc:           workflowNotificationsFunc,
-		testWorkflowServiceNotificationsWorkerCount:    proContext.WorkflowServiceNotificationsWorkerCount,
-		testWorkflowServiceNotificationsRequestBuffer:  make(chan *cloud.TestWorkflowServiceNotificationsRequest, bufferSizePerWorker*proContext.WorkflowServiceNotificationsWorkerCount),
-		testWorkflowServiceNotificationsResponseBuffer: make(chan *cloud.TestWorkflowServiceNotificationsResponse, bufferSizePerWorker*proContext.WorkflowServiceNotificationsWorkerCount),
-		testWorkflowServiceNotificationsFunc:           workflowServiceNotificationsFunc,
-
+		testWorkflowServiceNotificationsWorkerCount:         proContext.WorkflowServiceNotificationsWorkerCount,
+		testWorkflowServiceNotificationsRequestBuffer:       make(chan *cloud.TestWorkflowServiceNotificationsRequest, bufferSizePerWorker*proContext.WorkflowServiceNotificationsWorkerCount),
+		testWorkflowServiceNotificationsResponseBuffer:      make(chan *cloud.TestWorkflowServiceNotificationsResponse, bufferSizePerWorker*proContext.WorkflowServiceNotificationsWorkerCount),
+		testWorkflowServiceNotificationsFunc:                workflowServiceNotificationsFunc,
+		testWorkflowParallelStepNotificationsWorkerCount:    proContext.WorkflowParallelStepNotificationsWorkerCount,
+		testWorkflowParallelStepNotificationsRequestBuffer:  make(chan *cloud.TestWorkflowParallelStepNotificationsRequest, bufferSizePerWorker*proContext.WorkflowParallelStepNotificationsWorkerCount),
+		testWorkflowParallelStepNotificationsResponseBuffer: make(chan *cloud.TestWorkflowParallelStepNotificationsResponse, bufferSizePerWorker*proContext.WorkflowParallelStepNotificationsWorkerCount),
+		testWorkflowParallelStepNotificationsFunc:           workflowParallelStepNotificationsFunc,
 		clusterID:          clusterID,
 		clusterName:        clusterName,
 		features:           features,

pkg/agent/agent_test.go

@@ -106,6 +106,12 @@ func (cs *CloudServer) GetTestWorkflowServiceNotificationsStream(srv cloud.TestK
 	return nil
 }
 
+func (cs *CloudServer) GetTestWorkflowParallelStepNotificationsStream(srv cloud.TestKubeCloudAPI_GetTestWorkflowParallelStepNotificationsStreamServer) error {
+	<-cs.ctx.Done()
+
+	return nil
+}
+
 func (cs *CloudServer) ExecuteAsync(srv cloud.TestKubeCloudAPI_ExecuteAsyncServer) error {
 	md, ok := metadata.FromIncomingContext(srv.Context())
 	if !ok {

pkg/agent/events_test.go

@@ -119,6 +119,12 @@ func (cws *CloudEventServer) GetTestWorkflowServiceNotificationsStream(srv cloud
 	return nil
 }
 
+func (cws *CloudEventServer) GetTestWorkflowParallelStepNotificationsStream(srv cloud.TestKubeCloudAPI_GetTestWorkflowParallelStepNotificationsStreamServer) error {
+	<-cws.ctx.Done()
+
+	return nil
+}
+
 func (cws *CloudEventServer) Send(srv cloud.TestKubeCloudAPI_SendServer) error {
 	md, ok := metadata.FromIncomingContext(srv.Context())
 	if !ok {

pkg/agent/logs_test.go

@@ -110,6 +110,11 @@ func (cs *CloudLogsServer) GetTestWorkflowServiceNotificationsStream(srv cloud.T
 	return nil
 }
 
+func (cs *CloudLogsServer) GetTestWorkflowParallelStepNotificationsStream(srv cloud.TestKubeCloudAPI_GetTestWorkflowParallelStepNotificationsStreamServer) error {
+	<-cs.ctx.Done()
+	return nil
+}
+
 func (cs *CloudLogsServer) GetLogsStream(srv cloud.TestKubeCloudAPI_GetLogsStreamServer) error {
 	md, ok := metadata.FromIncomingContext(srv.Context())
 	if !ok {