diff --git a/cluster/manager/manager_test.go b/cluster/manager/manager_test.go index 6e18ac4bd..ed9b9bc80 100644 --- a/cluster/manager/manager_test.go +++ b/cluster/manager/manager_test.go @@ -143,15 +143,16 @@ func TestRemoveOnlineNode(t *testing.T) { err = kvdb.SetInstance(kv) assert.NoError(t, err) - // when force flag is false, node status check should take precedence + // when force flag is false, node status check should take precedence err = testManager.Remove([]api.Node{nodeToRemove}, false) - assert.ErrorContains(t, err, fmt.Sprintf(decommissionErrMsg, testNodeID)) + assert.Error(t, err) + assert.EqualError(t, err, fmt.Sprintf(decommissionErrMsg, testNodeID)) // when force flag is true, we shouldn't abort due to node status mockListener.EXPECT().String().Return(testNodeID) mockListener.EXPECT().MarkNodeDown(gomock.Any()).Return(mockErr) err = testManager.Remove([]api.Node{nodeToRemove}, true) - assert.ErrorIs(t, err, mockErr) + assert.EqualError(t, err, mockErr.Error()) }