X-Git-Url: https://git.arvados.org/arvados.git/blobdiff_plain/63cfe7a9b391e1a07c6c6c8b0fab10b1c875f1be..163c8f8750193b791eb62f5a8d73dc44a006b69e:/services/keepstore/pull_worker_integration_test.go diff --git a/services/keepstore/pull_worker_integration_test.go b/services/keepstore/pull_worker_integration_test.go index c0a7c6f6a5..231a4c0ab2 100644 --- a/services/keepstore/pull_worker_integration_test.go +++ b/services/keepstore/pull_worker_integration_test.go @@ -1,3 +1,7 @@ +// Copyright (C) The Arvados Authors. All rights reserved. +// +// SPDX-License-Identifier: AGPL-3.0 + package main import ( @@ -33,20 +37,19 @@ func SetupPullWorkerIntegrationTest(t *testing.T, testData PullWorkIntegrationTe // make arvadosclient arv, err := arvadosclient.MakeArvadosClient() if err != nil { - t.Error("Error creating arv") + t.Fatalf("Error creating arv: %s", err) } // keep client - keepClient = &keepclient.KeepClient{ - Arvados: arv, - Want_replicas: 1, + keepClient, err = keepclient.MakeKeepClient(arv) + if err != nil { + t.Fatalf("error creating KeepClient: %s", err) } + keepClient.Want_replicas = 1 + keepClient.RefreshServiceDiscovery() // discover keep services var servers []string - if err := keepClient.DiscoverKeepServers(); err != nil { - t.Error("Error discovering keep services") - } for _, host := range keepClient.LocalRoots() { servers = append(servers, host) }