use new task master during batch record

EmOne · Nov 3, 2015 · 3649e2c · 3649e2c
1 parent 5a65564
commit 3649e2c
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/.gitignore b/.gitignore
@@ -1,7 +1,7 @@
 .*.swp
 dist/*
-./kapacitor
-./kapacitord
+/kapacitor
+/kapacitord
 kapacitor_linux*
 kapacitord_linux*
 *~

diff --git a/services/replay/service.go b/services/replay/service.go
@@ -480,7 +480,7 @@ func (r *Service) doRecordStream(rid uuid.UUID, dur time.Duration, dbrps []kapac
 
 // Record a series of batch queries defined by a batch task
 func (r *Service) doRecordBatch(rid uuid.UUID, t *kapacitor.Task, start, stop time.Time) error {
-	et, err := kapacitor.NewExecutingTask(nil, t)
+	et, err := kapacitor.NewExecutingTask(r.TaskMaster.New(), t)
 	if err != nil {
 		return err
 	}