From 1e94ce1d408ff7d57e15034dc017bb8eb24f5c29 Mon Sep 17 00:00:00 2001 From: Gaurav Gahlot Date: Fri, 29 Apr 2022 16:56:54 +0530 Subject: [PATCH] =?UTF-8?q?=F0=9F=91=8C=20IMPROVE:=20resolve=20conflict?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit Signed-off-by: Gaurav Gahlot --- server/dbserver.go | 1 + server/dbserver_worker_workflow.go | 16 ---------------- 2 files changed, 1 insertion(+), 16 deletions(-) diff --git a/server/dbserver.go b/server/dbserver.go index 1fc7f8c1b..b30050988 100644 --- a/server/dbserver.go +++ b/server/dbserver.go @@ -18,6 +18,7 @@ const ( errInvalidActionName = "invalid action name" errInvalidTaskReported = "reported task name does not match the current action details" errInvalidActionReported = "reported action name does not match the current action details" + errInvalidActionIndex = "invalid action index for workflow" msgReceivedStatus = "received action status: %s" msgCurrentWfContext = "current workflow context" diff --git a/server/dbserver_worker_workflow.go b/server/dbserver_worker_workflow.go index 5348dcf12..ce89c9f3e 100644 --- a/server/dbserver_worker_workflow.go +++ b/server/dbserver_worker_workflow.go @@ -13,22 +13,6 @@ import ( "google.golang.org/grpc/status" ) -var workflowData = make(map[string]int) - -const ( - errInvalidWorkerID = "invalid worker id" - errInvalidWorkflowID = "invalid workflow id" - errInvalidTaskName = "invalid task name" - errInvalidActionName = "invalid action name" - errInvalidTaskReported = "reported task name does not match the current action details" - errInvalidActionReported = "reported action name does not match the current action details" - errInvalidActionIndex = "invalid action index for workflow" - - msgReceivedStatus = "received action status: %s" - msgCurrentWfContext = "current workflow context" - msgSendWfContext = "send workflow context: %s" -) - // GetWorkflowContexts implements tinkerbell.GetWorkflowContexts. func (s *DBServer) GetWorkflowContexts(req *workflow.WorkflowContextRequest, stream workflow.WorkflowService_GetWorkflowContextsServer) error { wfs, err := getWorkflowsForWorker(stream.Context(), s.db, req.WorkerId)