From 43d9748d3a85beb03c78d3b20fb471f0ad3c263c Mon Sep 17 00:00:00 2001 From: Kenichi Omichi Date: Mon, 30 Dec 2019 23:35:26 +0000 Subject: [PATCH] Add error handling for Register() call Register() can return an error as [1], so this adds the error handling. [1]: https://github.com/kubernetes/kubernetes/blob/f772c9017c16bbc983e59a19162814629a467cef/pkg/scheduler/framework/v1alpha1/registry.go#L56 --- test/integration/scheduler/preemption_test.go | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/test/integration/scheduler/preemption_test.go b/test/integration/scheduler/preemption_test.go index 677f7e3350f..ea4e06861c6 100644 --- a/test/integration/scheduler/preemption_test.go +++ b/test/integration/scheduler/preemption_test.go @@ -125,9 +125,12 @@ func TestPreemption(t *testing.T) { // Initialize scheduler with a filter plugin. var filter tokenFilter registry := make(framework.Registry) - registry.Register(filterPluginName, func(_ *runtime.Unknown, fh framework.FrameworkHandle) (framework.Plugin, error) { + err := registry.Register(filterPluginName, func(_ *runtime.Unknown, fh framework.FrameworkHandle) (framework.Plugin, error) { return &filter, nil }) + if err != nil { + t.Fatalf("Error registering a filter: %v", err) + } plugins := &schedulerconfig.Plugins{ Filter: &schedulerconfig.PluginSet{ Enabled: []schedulerconfig.Plugin{