projects
/
arvados.git
/ blobdiff
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
tree
raw
|
inline
| side by side
18995: Merge branch 'main' into 18995-code-cleanup-4
[arvados.git]
/
sdk
/
go
/
keepclient
/
keepclient.go
diff --git
a/sdk/go/keepclient/keepclient.go
b/sdk/go/keepclient/keepclient.go
index 4baebbd8a1913ae41f7a153fd4e87bb99ecce8d2..68ac886ddd8ede2809a56a577baedfd67604e7d1 100644
(file)
--- a/
sdk/go/keepclient/keepclient.go
+++ b/
sdk/go/keepclient/keepclient.go
@@
-141,10
+141,6
@@
func (kc *KeepClient) loadDefaultClasses() error {
// use.
func MakeKeepClient(arv *arvadosclient.ArvadosClient) (*KeepClient, error) {
kc := New(arv)
// use.
func MakeKeepClient(arv *arvadosclient.ArvadosClient) (*KeepClient, error) {
kc := New(arv)
- err := kc.loadDefaultClasses()
- if err != nil {
- DebugPrintf("DEBUG: Unable to load the default storage classes cluster config")
- }
return kc, kc.discoverServices()
}
return kc, kc.discoverServices()
}
@@
-159,11
+155,16
@@
func New(arv *arvadosclient.ArvadosClient) *KeepClient {
defaultReplicationLevel = int(v)
}
}
defaultReplicationLevel = int(v)
}
}
-
return
&KeepClient{
+
kc :=
&KeepClient{
Arvados: arv,
Want_replicas: defaultReplicationLevel,
Retries: 2,
}
Arvados: arv,
Want_replicas: defaultReplicationLevel,
Retries: 2,
}
+ err = kc.loadDefaultClasses()
+ if err != nil {
+ DebugPrintf("DEBUG: Unable to load the default storage classes cluster config")
+ }
+ return kc
}
// PutHR puts a block given the block hash, a reader, and the number of bytes
}
// PutHR puts a block given the block hash, a reader, and the number of bytes