[tq] Move to top-level package.

scheduler/appengine/engine/cron/demo/main.go

 // Copyright 2017 The LUCI Authors.
 //
 // Licensed under the Apache License, Version 2.0 (the "License");
 // you may not use this file except in compliance with the License.
 // You may obtain a copy of the License at
 //
 //      http://www.apache.org/licenses/LICENSE-2.0
 //
 // Unless required by applicable law or agreed to in writing, software
 // distributed under the License is distributed on an "AS IS" BASIS,
@@ skipping 12 matching lines @@
 
         "github.com/golang/protobuf/proto"
         "github.com/luci/gae/service/datastore"
 
         "github.com/luci/luci-go/appengine/gaemiddleware"
         "github.com/luci/luci-go/common/clock"
         "github.com/luci/luci-go/common/data/rand/mathrand"
         "github.com/luci/luci-go/common/logging"
         "github.com/luci/luci-go/server/router"
 
+        "github.com/luci/luci-go/appengine/tq"
         "github.com/luci/luci-go/scheduler/appengine/engine/cron"
         "github.com/luci/luci-go/scheduler/appengine/engine/internal"
-        "github.com/luci/luci-go/scheduler/appengine/engine/tq"
         "github.com/luci/luci-go/scheduler/appengine/schedule"
 )
 
 var tasks = tq.Dispatcher{}
 
 type CronState struct {
         _extra datastore.PropertyMap `gae:"-,extra"`
 
         ID    string     `gae:"$id"`
         State cron.State `gae:",noindex"`
@@ skipping 102 matching lines @@
 
         r.GET("/start/:JobID", gaemiddleware.BaseProd(), func(c *router.Context) {
                 jobID := c.Params.ByName("JobID")
                 if err := startJob(c.Context, jobID); err != nil {
                         panic(err)
                 }
         })
 
         http.DefaultServeMux.Handle("/", r)
 }