}
arvMountCmd = append(arvMountCmd, "--disk-cache", "--disk-cache-dir", keepcachedir, "--file-cache", fmt.Sprintf("%d", runner.Container.RuntimeConstraints.KeepCacheDisk))
} else if runner.Container.RuntimeConstraints.KeepCacheRAM > 0 {
- arvMountCmd = append(arvMountCmd, "--file-cache", fmt.Sprintf("%d", runner.Container.RuntimeConstraints.KeepCacheRAM))
+ arvMountCmd = append(arvMountCmd, "--ram-cache", "--file-cache", fmt.Sprintf("%d", runner.Container.RuntimeConstraints.KeepCacheRAM))
}
collectionPaths := []string{}
return ErrCancelled
}
return runner.DispatcherArvClient.Update("containers", runner.Container.UUID,
- arvadosclient.Dict{"container": arvadosclient.Dict{"state": "Running", "gateway_address": runner.gateway.Address}}, nil)
+ arvadosclient.Dict{"container": arvadosclient.Dict{
+ "state": "Running",
+ "gateway_address": runner.gateway.Address,
+ "log": runner.logUUID,
+ }}, nil)
}
// ContainerToken returns the api_token the container (and any
return
}
+ _, err = runner.saveLogCollection(false)
+ if err != nil {
+ runner.CrunchLog.Printf("Error committing initial log collection: %v", err)
+ }
err = runner.UpdateContainerRunning()
if err != nil {
return