functions: upgrade runner to latest (#434)

* functions: upgrade runner

* functions: update to latest runner

Supercedes and fixes #433
This commit is contained in:
C Cirello
2016-12-14 00:10:24 +01:00
committed by GitHub
parent 43652b0198
commit 1dc3145045
3 changed files with 59 additions and 68 deletions

View File

@@ -195,15 +195,15 @@ func (r *Runner) Run(ctx context.Context, cfg *task.Config) (drivers.RunResult,
}
defer r.addUsedMem(-1 * int64(cfg.Memory))
closer, err := r.driver.Prepare(ctx, ctask)
cookie, err := r.driver.Prepare(ctx, ctask)
if err != nil {
return nil, err
}
defer closer.Close()
defer cookie.Close()
metricStart := time.Now()
result, err := r.driver.Run(ctx, ctask)
result, err := cookie.Run(ctx)
if err != nil {
return nil, err
}