}
client.mtx.Lock()
for ch := range client.notifying[msg.ObjectUUID] {
- ch <- msg
+ go func() { ch <- msg }()
}
client.mtx.Unlock()
}
keepCache = 2
}
rc := arvados.RuntimeConstraints{
- API: &runner.APIAccess,
+ API: runner.APIAccess,
VCPUs: runner.VCPUs,
RAM: runner.RAM,
KeepCacheRAM: (1 << 26) * int64(keepCache) * int64(runner.VCPUs),