- Arv: arv,
- PollInterval: time.Duration(1) * time.Second,
- RunContainer: func(dispatcher *dispatch.Dispatcher,
- container arvados.Container,
- status chan arvados.Container) {
- run(dispatcher, container, status)
- doneProcessing <- struct{}{}
- },
- DoneProcessing: doneProcessing}
-
- startCmd = func(container arvados.Container, cmd *exec.Cmd) error {
+ Arv: arv,
+ PollPeriod: time.Second / 20,
+ }
+
+ startCmd := func(container arvados.Container, cmd *exec.Cmd) error {