}
func (conn *Conn) VocabularyGet(ctx context.Context) (arvados.Vocabulary, error) {
- return conn.chooseBackend(conn.cluster.ClusterID).VocabularyGet(ctx)
+ return conn.local.VocabularyGet(ctx)
}
func (conn *Conn) DiscoveryDocument(ctx context.Context) (arvados.DiscoveryDocument, error) {
- return conn.chooseBackend(conn.cluster.ClusterID).DiscoveryDocument(ctx)
+ return conn.local.DiscoveryDocument(ctx)
}
func (conn *Conn) Login(ctx context.Context, options arvados.LoginOptions) (arvados.LoginResponse, error) {
return conn.chooseBackend(options.UUID).ContainerRequestDelete(ctx, options)
}
+func (conn *Conn) ContainerRequestContainerStatus(ctx context.Context, options arvados.GetOptions) (arvados.ContainerStatus, error) {
+ return conn.chooseBackend(options.UUID).ContainerRequestContainerStatus(ctx, options)
+}
+
func (conn *Conn) ContainerRequestLog(ctx context.Context, options arvados.ContainerLogOptions) (http.Handler, error) {
return conn.chooseBackend(options.UUID).ContainerRequestLog(ctx, options)
}
delete(updates, "is_admin")
delete(updates, "is_invited")
}
- fmt.Printf("updates %v", updates)
batchOpts.Updates[user.UUID] = updates
}
if len(batchOpts.Updates) > 0 {
// fields aren't actually valid then we don't want to
// send them in the batch update.
dd, err := be.DiscoveryDocument(ctx)
+ if err != nil {
+ // couldn't get discovery document
+ return false, err
+ }
if dd.Revision >= "20231117" {
// newer version, fields are valid.
return true, nil