"--storage-classes", strings.Join(runner.Container.OutputStorageClasses, ","),
fmt.Sprintf("--crunchstat-interval=%v", runner.statInterval.Seconds())}
- if runner.executor.Runtime() == "docker" {
+ if _, isdocker := runner.executor.(*dockerExecutor); isdocker {
arvMountCmd = append(arvMountCmd, "--allow-other")
}
func (runner *ContainerRunner) Run() (err error) {
runner.CrunchLog.Printf("crunch-run %s started", cmd.Version.String())
runner.CrunchLog.Printf("%s", currentUserAndGroups())
- runner.CrunchLog.Printf("Executing container '%s' using %s runtime", runner.Container.UUID, runner.executor.Runtime())
+ v, _ := exec.Command("arv-mount", "--version").CombinedOutput()
+ runner.CrunchLog.Printf("Using FUSE mount: %s", v)
+ runner.CrunchLog.Printf("Using container runtime: %s", runner.executor.Runtime())
+ runner.CrunchLog.Printf("Executing container: %s", runner.Container.UUID)
hostname, hosterr := os.Hostname()
if hosterr != nil {
ldr.Path = path
cfg, err := ldr.Load()
if err != nil {
- fmt.Fprintf(stderr, "could not load config file %s: %s", path, err)
+ fmt.Fprintf(stderr, "could not load config file %s: %s\n", path, err)
return nil
}
cluster, err := cfg.GetCluster("")
if err != nil {
- fmt.Fprintf(stderr, "could not use config file %s: %s", path, err)
+ fmt.Fprintf(stderr, "could not use config file %s: %s\n", path, err)
return nil
}
+ fmt.Fprintf(stderr, "loaded config file %s\n", path)
return cluster
}