Replaced context.TODO()-->context. Background()

Signed-off-by: yanggang <[email protected]>
vmware-tanzu · Sep 21, 2023 · 1d185bf · 1d185bf
1 parent b272542
commit 1d185bf
Show file tree

Hide file tree

Showing 82 changed files with 320 additions and 224 deletions.
diff --git a/internal/delete/delete_item_action_handler_test.go b/internal/delete/delete_item_action_handler_test.go
@@ -221,9 +221,9 @@ func (h *harness) addResource(t *testing.T, resource *test.APIResource) {
 
 		unstructuredObj := &unstructured.Unstructured{Object: obj}
 		if resource.Namespaced {
-			_, err = h.DynamicClient.Resource(resource.GVR()).Namespace(item.GetNamespace()).Create(context.TODO(), unstructuredObj, metav1.CreateOptions{})
+			_, err = h.DynamicClient.Resource(resource.GVR()).Namespace(item.GetNamespace()).Create(context.Background(), unstructuredObj, metav1.CreateOptions{})
 		} else {
-			_, err = h.DynamicClient.Resource(resource.GVR()).Create(context.TODO(), unstructuredObj, metav1.CreateOptions{})
+			_, err = h.DynamicClient.Resource(resource.GVR()).Create(context.Background(), unstructuredObj, metav1.CreateOptions{})
 		}
 		require.NoError(t, err)
 	}

diff --git a/pkg/backup/backup_test.go b/pkg/backup/backup_test.go
@@ -3254,9 +3254,9 @@ func (h *harness) addItems(t *testing.T, resource *test.APIResource) {
 		unstructuredObj := &unstructured.Unstructured{Object: obj}
 
 		if resource.Namespaced {
-			_, err = h.DynamicClient.Resource(resource.GVR()).Namespace(item.GetNamespace()).Create(context.TODO(), unstructuredObj, metav1.CreateOptions{})
+			_, err = h.DynamicClient.Resource(resource.GVR()).Namespace(item.GetNamespace()).Create(context.Background(), unstructuredObj, metav1.CreateOptions{})
 		} else {
-			_, err = h.DynamicClient.Resource(resource.GVR()).Create(context.TODO(), unstructuredObj, metav1.CreateOptions{})
+			_, err = h.DynamicClient.Resource(resource.GVR()).Create(context.Background(), unstructuredObj, metav1.CreateOptions{})
 		}
 		require.NoError(t, err)
 	}

diff --git a/pkg/backup/rbac.go b/pkg/backup/rbac.go
@@ -47,7 +47,7 @@ type v1ClusterRoleBindingLister struct {
 }
 
 func (v1 v1ClusterRoleBindingLister) List() ([]ClusterRoleBinding, error) {
-	crbList, err := v1.client.List(context.TODO(), metav1.ListOptions{})
+	crbList, err := v1.client.List(context.Background(), metav1.ListOptions{})
 	if err != nil {
 		return nil, errors.WithStack(err)
 	}
@@ -64,7 +64,7 @@ type v1beta1ClusterRoleBindingLister struct {
 }
 
 func (v1beta1 v1beta1ClusterRoleBindingLister) List() ([]ClusterRoleBinding, error) {
-	crbList, err := v1beta1.client.List(context.TODO(), metav1.ListOptions{})
+	crbList, err := v1beta1.client.List(context.Background(), metav1.ListOptions{})
 	if err != nil {
 		return nil, errors.WithStack(err)
 	}

diff --git a/pkg/backup/remap_crd_version_action.go b/pkg/backup/remap_crd_version_action.go
@@ -122,7 +122,7 @@ CheckVersion:
 }
 
 func fetchV1beta1CRD(name string, betaCRDClient apiextv1beta1client.CustomResourceDefinitionInterface) (*unstructured.Unstructured, error) {
-	betaCRD, err := betaCRDClient.Get(context.TODO(), name, metav1.GetOptions{})
+	betaCRD, err := betaCRDClient.Get(context.Background(), name, metav1.GetOptions{})
 	if err != nil {
 		return nil, errors.Wrapf(err, "error fetching v1beta1 version of %s", name)
 	}

diff --git a/pkg/backup/remap_crd_version_action_test.go b/pkg/backup/remap_crd_version_action_test.go
@@ -48,7 +48,7 @@ func TestRemapCRDVersionAction(t *testing.T) {
 	// keep the same one for all 3 tests, since there's little value in recreating it
 	b := builder.ForCustomResourceDefinitionV1Beta1("test.velero.io")
 	c := b.Result()
-	_, err := betaClient.Create(context.TODO(), c, metav1.CreateOptions{})
+	_, err := betaClient.Create(context.Background(), c, metav1.CreateOptions{})
 	require.NoError(t, err)
 	a := NewRemapCRDVersionAction(velerotest.NewLogger(), betaClient, fakeDiscoveryHelper())
 
@@ -190,7 +190,7 @@ func TestRemapCRDVersionActionData(t *testing.T) {
 			err = json.Unmarshal(f, &crd)
 			require.NoError(t, err)
 
-			_, err = betaClient.Create(context.TODO(), &crd, metav1.CreateOptions{})
+			_, err = betaClient.Create(context.Background(), &crd, metav1.CreateOptions{})
 			require.NoError(t, err)
 
 			// Run method under test
@@ -214,7 +214,7 @@ func TestRemapCRDVersionActionData(t *testing.T) {
 			}
 
 			// Clean up the item created in the test.
-			betaClient.Delete(context.TODO(), crd.Name, metav1.DeleteOptions{})
+			betaClient.Delete(context.Background(), crd.Name, metav1.DeleteOptions{})
 		})
 	}
 

diff --git a/pkg/client/dynamic.go b/pkg/client/dynamic.go
@@ -113,29 +113,29 @@ type dynamicResourceClient struct {
 var _ Dynamic = &dynamicResourceClient{}
 
 func (d *dynamicResourceClient) Create(obj *unstructured.Unstructured) (*unstructured.Unstructured, error) {
-	return d.resourceClient.Create(context.TODO(), obj, metav1.CreateOptions{})
+	return d.resourceClient.Create(context.Background(), obj, metav1.CreateOptions{})
 }
 
 func (d *dynamicResourceClient) List(options metav1.ListOptions) (*unstructured.UnstructuredList, error) {
-	return d.resourceClient.List(context.TODO(), options)
+	return d.resourceClient.List(context.Background(), options)
 }
 
 func (d *dynamicResourceClient) Watch(options metav1.ListOptions) (watch.Interface, error) {
-	return d.resourceClient.Watch(context.TODO(), options)
+	return d.resourceClient.Watch(context.Background(), options)
 }
 
 func (d *dynamicResourceClient) Get(name string, opts metav1.GetOptions) (*unstructured.Unstructured, error) {
-	return d.resourceClient.Get(context.TODO(), name, opts)
+	return d.resourceClient.Get(context.Background(), name, opts)
 }
 
 func (d *dynamicResourceClient) Patch(name string, data []byte) (*unstructured.Unstructured, error) {
-	return d.resourceClient.Patch(context.TODO(), name, types.MergePatchType, data, metav1.PatchOptions{})
+	return d.resourceClient.Patch(context.Background(), name, types.MergePatchType, data, metav1.PatchOptions{})
 }
 
 func (d *dynamicResourceClient) Delete(name string, opts metav1.DeleteOptions) error {
-	return d.resourceClient.Delete(context.TODO(), name, opts)
+	return d.resourceClient.Delete(context.Background(), name, opts)
 }
 
 func (d *dynamicResourceClient) UpdateStatus(obj *unstructured.Unstructured, opts metav1.UpdateOptions) (*unstructured.Unstructured, error) {
-	return d.resourceClient.UpdateStatus(context.TODO(), obj, opts)
+	return d.resourceClient.UpdateStatus(context.Background(), obj, opts)
 }
diff --git a/pkg/cmd/cli/backup/create.go b/pkg/cmd/cli/backup/create.go
@@ -186,7 +186,7 @@ func (o *CreateOptions) Validate(c *cobra.Command, args []string, f client.Facto
 
 	if o.StorageLocation != "" {
 		location := &velerov1api.BackupStorageLocation{}
-		if err := o.client.Get(context.TODO(), kbclient.ObjectKey{
+		if err := o.client.Get(context.Background(), kbclient.ObjectKey{
 			Namespace: f.Namespace(),
 			Name:      o.StorageLocation,
 		}, location); err != nil {
@@ -196,7 +196,7 @@ func (o *CreateOptions) Validate(c *cobra.Command, args []string, f client.Facto
 
 	for _, loc := range o.SnapshotLocations {
 		snapshotLocation := new(velerov1api.VolumeSnapshotLocation)
-		if err := o.client.Get(context.TODO(), kbclient.ObjectKey{Namespace: f.Namespace(), Name: loc}, snapshotLocation); err != nil {
+		if err := o.client.Get(context.Background(), kbclient.ObjectKey{Namespace: f.Namespace(), Name: loc}, snapshotLocation); err != nil {
 			return err
 		}
 	}
@@ -276,7 +276,7 @@ func (o *CreateOptions) Run(c *cobra.Command, f client.Factory) error {
 		go backupInformer.Run(stop)
 	}
 
-	err = o.client.Create(context.TODO(), backup, &kbclient.CreateOptions{})
+	err = o.client.Create(context.Background(), backup, &kbclient.CreateOptions{})
 	if err != nil {
 		return err
 	}
@@ -340,7 +340,7 @@ func (o *CreateOptions) BuildBackup(namespace string) (*velerov1api.Backup, erro
 
 	if o.FromSchedule != "" {
 		schedule := new(velerov1api.Schedule)
-		err := o.client.Get(context.TODO(), kbclient.ObjectKey{Namespace: namespace, Name: o.FromSchedule}, schedule)
+		err := o.client.Get(context.Background(), kbclient.ObjectKey{Namespace: namespace, Name: o.FromSchedule}, schedule)
 		if err != nil {
 			return nil, err
 		}

diff --git a/pkg/cmd/cli/backup/create_test.go b/pkg/cmd/cli/backup/create_test.go
@@ -87,7 +87,7 @@ func TestCreateOptions_BuildBackupFromSchedule(t *testing.T) {
 
 	expectedBackupSpec := builder.ForBackup("test", cmdtest.VeleroNameSpace).IncludedNamespaces("test").Result().Spec
 	schedule := builder.ForSchedule(cmdtest.VeleroNameSpace, "test").Template(expectedBackupSpec).ObjectMeta(builder.WithLabels("velero.io/test", "true"), builder.WithAnnotations("velero.io/test", "true")).Result()
-	o.client.Create(context.TODO(), schedule, &kbclient.CreateOptions{})
+	o.client.Create(context.Background(), schedule, &kbclient.CreateOptions{})
 
 	t.Run("existing schedule", func(t *testing.T) {
 		backup, err := o.BuildBackup(cmdtest.VeleroNameSpace)

diff --git a/pkg/cmd/cli/backup/delete.go b/pkg/cmd/cli/backup/delete.go
@@ -85,7 +85,7 @@ func Run(o *cli.DeleteOptions) error {
 	case len(o.Names) > 0:
 		for _, name := range o.Names {
 			backup := new(velerov1api.Backup)
-			err := o.Client.Get(context.TODO(), controllerclient.ObjectKey{Namespace: o.Namespace, Name: name}, backup)
+			err := o.Client.Get(context.Background(), controllerclient.ObjectKey{Namespace: o.Namespace, Name: name}, backup)
 			if err != nil {
 				errs = append(errs, errors.WithStack(err))
 				continue
@@ -104,7 +104,7 @@ func Run(o *cli.DeleteOptions) error {
 		}
 
 		backupList := new(velerov1api.BackupList)
-		err := o.Client.List(context.TODO(), backupList, &controllerclient.ListOptions{LabelSelector: selector, Namespace: o.Namespace})
+		err := o.Client.List(context.Background(), backupList, &controllerclient.ListOptions{LabelSelector: selector, Namespace: o.Namespace})
 		if err != nil {
 			return errors.WithStack(err)
 		}
@@ -124,7 +124,7 @@ func Run(o *cli.DeleteOptions) error {
 			ObjectMeta(builder.WithLabels(velerov1api.BackupNameLabel, label.GetValidName(b.Name),
 				velerov1api.BackupUIDLabel, string(b.UID)), builder.WithGenerateName(b.Name+"-")).Result()
 
-		if err := o.Client.Create(context.TODO(), deleteRequest, &controllerclient.CreateOptions{}); err != nil {
+		if err := o.Client.Create(context.Background(), deleteRequest, &controllerclient.CreateOptions{}); err != nil {
 			errs = append(errs, err)
 			continue
 		}

diff --git a/pkg/cmd/cli/backup/describe.go b/pkg/cmd/cli/backup/describe.go
@@ -73,21 +73,21 @@ func NewDescribeCommand(f client.Factory, use string) *cobra.Command {
 			if len(args) > 0 {
 				for _, name := range args {
 					backup := new(velerov1api.Backup)
-					err := kbClient.Get(context.TODO(), controllerclient.ObjectKey{Namespace: f.Namespace(), Name: name}, backup)
+					err := kbClient.Get(context.Background(), controllerclient.ObjectKey{Namespace: f.Namespace(), Name: name}, backup)
 					cmd.CheckError(err)
 					backups.Items = append(backups.Items, *backup)
 				}
 			} else {
 				parsedSelector, err := labels.Parse(listOptions.LabelSelector)
 				cmd.CheckError(err)
-				err = kbClient.List(context.TODO(), backups, &controllerclient.ListOptions{LabelSelector: parsedSelector, Namespace: f.Namespace()})
+				err = kbClient.List(context.Background(), backups, &controllerclient.ListOptions{LabelSelector: parsedSelector, Namespace: f.Namespace()})
 				cmd.CheckError(err)
 			}
 
 			first := true
 			for i, backup := range backups.Items {
 				deleteRequestList := new(velerov1api.DeleteBackupRequestList)
-				err := kbClient.List(context.TODO(), deleteRequestList, &controllerclient.ListOptions{
+				err := kbClient.List(context.Background(), deleteRequestList, &controllerclient.ListOptions{
 					Namespace:     f.Namespace(),
 					LabelSelector: labels.SelectorFromSet(map[string]string{velerov1api.BackupNameLabel: label.GetValidName(backup.Name), velerov1api.BackupUIDLabel: string(backup.UID)}),
 				})
@@ -96,7 +96,7 @@ func NewDescribeCommand(f client.Factory, use string) *cobra.Command {
 				}
 
 				podVolumeBackupList := new(velerov1api.PodVolumeBackupList)
-				err = kbClient.List(context.TODO(), podVolumeBackupList, &controllerclient.ListOptions{
+				err = kbClient.List(context.Background(), podVolumeBackupList, &controllerclient.ListOptions{
 					Namespace:     f.Namespace(),
 					LabelSelector: labels.SelectorFromSet(map[string]string{velerov1api.BackupNameLabel: label.GetValidName(backup.Name)}),
 				})
@@ -108,7 +108,7 @@ func NewDescribeCommand(f client.Factory, use string) *cobra.Command {
 				vscList := new(snapshotv1api.VolumeSnapshotContentList)
 				if features.IsEnabled(velerov1api.CSIFeatureFlag) {
 					opts := label.NewListOptionsForBackup(backup.Name)
-					vscList, err = csiClient.SnapshotV1().VolumeSnapshotContents().List(context.TODO(), opts)
+					vscList, err = csiClient.SnapshotV1().VolumeSnapshotContents().List(context.Background(), opts)
 					if err != nil {
 						fmt.Fprintf(os.Stderr, "error getting VolumeSnapshotContent objects for backup %s: %v\n", backup.Name, err)
 					}

diff --git a/pkg/cmd/cli/backup/download.go b/pkg/cmd/cli/backup/download.go
@@ -88,7 +88,7 @@ func (o *DownloadOptions) Validate(c *cobra.Command, args []string, f client.Fac
 	cmd.CheckError(err)
 
 	backup := new(velerov1api.Backup)
-	if err := kbClient.Get(context.TODO(), controllerclient.ObjectKey{Namespace: f.Namespace(), Name: o.Name}, backup); err != nil {
+	if err := kbClient.Get(context.Background(), controllerclient.ObjectKey{Namespace: f.Namespace(), Name: o.Name}, backup); err != nil {
 		return err
 	}
 

diff --git a/pkg/cmd/cli/backup/get.go b/pkg/cmd/cli/backup/get.go
@@ -47,14 +47,14 @@ func NewGetCommand(f client.Factory, use string) *cobra.Command {
 			if len(args) > 0 {
 				for _, name := range args {
 					backup := new(api.Backup)
-					err := kbClient.Get(context.TODO(), kbclient.ObjectKey{Namespace: f.Namespace(), Name: name}, backup)
+					err := kbClient.Get(context.Background(), kbclient.ObjectKey{Namespace: f.Namespace(), Name: name}, backup)
 					cmd.CheckError(err)
 					backups.Items = append(backups.Items, *backup)
 				}
 			} else {
 				parsedSelector, err := labels.Parse(listOptions.LabelSelector)
 				cmd.CheckError(err)
-				err = kbClient.List(context.TODO(), backups, &kbclient.ListOptions{
+				err = kbClient.List(context.Background(), backups, &kbclient.ListOptions{
 					LabelSelector: parsedSelector,
 					Namespace:     f.Namespace(),
 				})

diff --git a/pkg/cmd/cli/backup/logs.go b/pkg/cmd/cli/backup/logs.go
@@ -62,7 +62,7 @@ func (l *LogsOptions) BindFlags(flags *pflag.FlagSet) {
 
 func (l *LogsOptions) Run(c *cobra.Command, f client.Factory) error {
 	backup := new(velerov1api.Backup)
-	err := l.Client.Get(context.TODO(), kbclient.ObjectKey{Namespace: f.Namespace(), Name: l.BackupName}, backup)
+	err := l.Client.Get(context.Background(), kbclient.ObjectKey{Namespace: f.Namespace(), Name: l.BackupName}, backup)
 	if apierrors.IsNotFound(err) {
 		return fmt.Errorf("backup %q does not exist", l.BackupName)
 	} else if err != nil {

diff --git a/pkg/cmd/cli/debug/debug.go b/pkg/cmd/cli/debug/debug.go
@@ -114,7 +114,7 @@ func (o *option) validate(f client.Factory) error {
 	if err != nil {
 		return err
 	}
-	l, err := kubeClient.AppsV1().Deployments(o.namespace).List(context.TODO(), metav1.ListOptions{
+	l, err := kubeClient.AppsV1().Deployments(o.namespace).List(context.Background(), metav1.ListOptions{
 		LabelSelector: "component=velero",
 	})
 	if err != nil {
@@ -128,12 +128,12 @@ func (o *option) validate(f client.Factory) error {
 		return err
 	}
 	if len(o.backup) > 0 {
-		if _, err := veleroClient.VeleroV1().Backups(o.namespace).Get(context.TODO(), o.backup, metav1.GetOptions{}); err != nil {
+		if _, err := veleroClient.VeleroV1().Backups(o.namespace).Get(context.Background(), o.backup, metav1.GetOptions{}); err != nil {
 			return err
 		}
 	}
 	if len(o.restore) > 0 {
-		if _, err := veleroClient.VeleroV1().Restores(o.namespace).Get(context.TODO(), o.restore, metav1.GetOptions{}); err != nil {
+		if _, err := veleroClient.VeleroV1().Restores(o.namespace).Get(context.Background(), o.restore, metav1.GetOptions{}); err != nil {
 			return err
 		}
 	}

diff --git a/pkg/cmd/cli/nodeagent/server_test.go b/pkg/cmd/cli/nodeagent/server_test.go
@@ -87,7 +87,7 @@ func Test_validatePodVolumesHostPath(t *testing.T) {
 
 			kubeClient := fake.NewSimpleClientset()
 			for _, pod := range tt.pods {
-				_, err := kubeClient.CoreV1().Pods(pod.GetNamespace()).Create(context.TODO(), pod, metav1.CreateOptions{})
+				_, err := kubeClient.CoreV1().Pods(pod.GetNamespace()).Create(context.Background(), pod, metav1.CreateOptions{})
 				if err != nil {
 					t.Error(err)
 				}

diff --git a/pkg/cmd/cli/plugin/add.go b/pkg/cmd/cli/plugin/add.go
@@ -56,7 +56,7 @@ func NewAddCommand(f client.Factory) *cobra.Command {
 				cmd.CheckError(err)
 			}
 
-			veleroDeploy, err := veleroDeployment(context.TODO(), kubeClient, f.Namespace())
+			veleroDeploy, err := veleroDeployment(context.Background(), kubeClient, f.Namespace())
 			if err != nil {
 				cmd.CheckError(err)
 			}
@@ -116,7 +116,7 @@ func NewAddCommand(f client.Factory) *cobra.Command {
 			patchBytes, err := jsonpatch.CreateMergePatch(original, updated)
 			cmd.CheckError(err)
 
-			_, err = kubeClient.AppsV1().Deployments(veleroDeploy.Namespace).Patch(context.TODO(), veleroDeploy.Name, types.MergePatchType, patchBytes, metav1.PatchOptions{})
+			_, err = kubeClient.AppsV1().Deployments(veleroDeploy.Namespace).Patch(context.Background(), veleroDeploy.Name, types.MergePatchType, patchBytes, metav1.PatchOptions{})
 			cmd.CheckError(err)
 		},
 	}

diff --git a/pkg/cmd/cli/plugin/remove.go b/pkg/cmd/cli/plugin/remove.go
@@ -41,7 +41,7 @@ func NewRemoveCommand(f client.Factory) *cobra.Command {
 				cmd.CheckError(err)
 			}
 
-			veleroDeploy, err := veleroDeployment(context.TODO(), kubeClient, f.Namespace())
+			veleroDeploy, err := veleroDeployment(context.Background(), kubeClient, f.Namespace())
 			if err != nil {
 				cmd.CheckError(err)
 			}
@@ -73,7 +73,7 @@ func NewRemoveCommand(f client.Factory) *cobra.Command {
 			patchBytes, err := jsonpatch.CreateMergePatch(original, updated)
 			cmd.CheckError(err)
 
-			_, err = kubeClient.AppsV1().Deployments(veleroDeploy.Namespace).Patch(context.TODO(), veleroDeploy.Name, types.MergePatchType, patchBytes, metav1.PatchOptions{})
+			_, err = kubeClient.AppsV1().Deployments(veleroDeploy.Namespace).Patch(context.Background(), veleroDeploy.Name, types.MergePatchType, patchBytes, metav1.PatchOptions{})
 			cmd.CheckError(err)
 		},
 	}

diff --git a/pkg/cmd/cli/repo/get.go b/pkg/cmd/cli/repo/get.go
@@ -45,12 +45,12 @@ func NewGetCommand(f client.Factory, use string) *cobra.Command {
 			if len(args) > 0 {
 				repos = new(api.BackupRepositoryList)
 				for _, name := range args {
-					repo, err := veleroClient.VeleroV1().BackupRepositories(f.Namespace()).Get(context.TODO(), name, metav1.GetOptions{})
+					repo, err := veleroClient.VeleroV1().BackupRepositories(f.Namespace()).Get(context.Background(), name, metav1.GetOptions{})
 					cmd.CheckError(err)
 					repos.Items = append(repos.Items, *repo)
 				}
 			} else {
-				repos, err = veleroClient.VeleroV1().BackupRepositories(f.Namespace()).List(context.TODO(), listOptions)
+				repos, err = veleroClient.VeleroV1().BackupRepositories(f.Namespace()).List(context.Background(), listOptions)
 				cmd.CheckError(err)
 			}
 

diff --git a/pkg/cmd/cli/restore/create.go b/pkg/cmd/cli/restore/create.go
@@ -192,12 +192,12 @@ func (o *CreateOptions) Validate(c *cobra.Command, args []string, f client.Facto
 	switch {
 	case o.BackupName != "":
 		backup := new(api.Backup)
-		if err := o.client.Get(context.TODO(), kbclient.ObjectKey{Namespace: f.Namespace(), Name: o.BackupName}, backup); err != nil {
+		if err := o.client.Get(context.Background(), kbclient.ObjectKey{Namespace: f.Namespace(), Name: o.BackupName}, backup); err != nil {
 			return err
 		}
 	case o.ScheduleName != "":
 		backupList := new(api.BackupList)
-		err := o.client.List(context.TODO(), backupList, &kbclient.ListOptions{
+		err := o.client.List(context.Background(), backupList, &kbclient.ListOptions{
 			LabelSelector: labels.SelectorFromSet(map[string]string{api.ScheduleNameLabel: o.ScheduleName}),
 			Namespace:     f.Namespace(),
 		})
@@ -259,7 +259,7 @@ func (o *CreateOptions) Run(c *cobra.Command, f client.Factory) error {
 	// to restore from.
 	if o.ScheduleName != "" && boolptr.IsSetToTrue(o.AllowPartiallyFailed.Value) {
 		backupList := new(api.BackupList)
-		err := o.client.List(context.TODO(), backupList, &kbclient.ListOptions{
+		err := o.client.List(context.Background(), backupList, &kbclient.ListOptions{
 			LabelSelector: labels.SelectorFromSet(map[string]string{api.ScheduleNameLabel: o.ScheduleName}),
 			Namespace:     f.Namespace(),
 		})
@@ -369,7 +369,7 @@ func (o *CreateOptions) Run(c *cobra.Command, f client.Factory) error {
 		go restoreInformer.Run(stop)
 	}
 
-	err := o.client.Create(context.TODO(), restore, &kbclient.CreateOptions{})
+	err := o.client.Create(context.Background(), restore, &kbclient.CreateOptions{})
 	if err != nil {
 		return err
 	}