From c9d792d266c93957bc22f529e792d3cf56d8311b Mon Sep 17 00:00:00 2001 From: Sean Breen Date: Mon, 20 Jan 2025 16:23:04 +0000 Subject: [PATCH] fix bad merge --- internal/command/command_service.go | 19 ------------------- 1 file changed, 19 deletions(-) diff --git a/internal/command/command_service.go b/internal/command/command_service.go index 1139c187b..78bd7df08 100644 --- a/internal/command/command_service.go +++ b/internal/command/command_service.go @@ -435,25 +435,6 @@ func (cs *CommandService) receiveCallback(ctx context.Context) func() error { cs.subscribeChannel <- request } } - switch request.GetRequest().(type) { - case *mpi.ManagementPlaneRequest_ConfigApplyRequest: - cs.configApplyRequestQueueMutex.Lock() - defer cs.configApplyRequestQueueMutex.Unlock() - - instanceID := request.GetConfigApplyRequest().GetOverview().GetConfigVersion().GetInstanceId() - cs.configApplyRequestQueue[instanceID] = append(cs.configApplyRequestQueue[instanceID], request) - if len(cs.configApplyRequestQueue[instanceID]) == 1 { - cs.subscribeChannel <- request - } else { - slog.DebugContext( - ctx, - "Config apply request is already in progress, queuing new config apply request", - "request", request, - ) - } - default: - cs.subscribeChannel <- request - } return nil }