update logging package

Signed-off-by: WashingtonKK <[email protected]>

agent/algorithm/logging_test.go

@@ -73,7 +73,7 @@ func TestStderrWrite(t *testing.T) {
 	for _, tt := range tests {
 		t.Run(tt.name, func(t *testing.T) {
 			mockEventService := mocks.NewService(t)
-			mockEventService.On("SendEvent", "AlgorithmRun", manager.Error.String(), mock.Anything).Return(nil)
+			mockEventService.On("SendEvent", "AlgorithmRun", manager.Warning.String(), mock.Anything).Return(nil)
 
 			stderr := &Stderr{Logger: mglog.NewMock(), EventSvc: mockEventService}
 			n, err := stderr.Write([]byte(tt.input))

manager/vm/logging.go

@@ -121,7 +121,7 @@ func (s *Stderr) Write(p []byte) (n int, err error) {
 				EventType:     manager.VmRunning.String(),
 				Timestamp:     timestamppb.Now(),
 				Originator:    "manager",
-				Status:        manager.Error.String(),
+				Status:        manager.Warning.String(),
 			},
 		},
 	}

manager/vm/logging_test.go

@@ -122,7 +122,7 @@ func TestStderrWrite(t *testing.T) {
 						assert.NotNil(t, agentEvent)
 						assert.Equal(t, "test-computation", agentEvent.ComputationId)
 						assert.Equal(t, manager.VmRunning.String(), agentEvent.EventType)
-						assert.Equal(t, manager.Error.String(), agentEvent.Status)
+						assert.Equal(t, manager.Warning.String(), agentEvent.Status)
 						assert.NotNil(t, agentEvent.Timestamp)
 					}
 				case <-time.After(time.Second):

pkg/manager/manager_states.go

@@ -17,6 +17,6 @@ type ManagerStatus uint8
 const (
 	Starting ManagerStatus = iota
 	Stopped
-	Error
+	Warning
 	Disconnected
 )