build kv based TaskService (#13228)

* chore(tasks): task kv * WIP * get the kv task service complete and passing test
influxdata · Apr 9, 2019 · c29e77e · c29e77e
1 parent 2463114
commit c29e77e
Show file tree

Hide file tree

Showing 6 changed files with 2,014 additions and 172 deletions.
diff --git a/kv/service.go b/kv/service.go
@@ -77,6 +77,10 @@ func (s *Service) Initialize(ctx context.Context) error {
 			return err
 		}
 
+		if err := s.initializeTasks(ctx, tx); err != nil {
+			return err
+		}
+
 		if err := s.initializePasswords(ctx, tx); err != nil {
 			return err
 		}