diff options
| author | Paul Buetow <paul@buetow.org> | 2021-10-29 12:13:55 +0300 |
|---|---|---|
| committer | Paul Buetow <paul@buetow.org> | 2021-10-29 12:13:55 +0300 |
| commit | a5f0c021f2caecf9adfec65583c915b6c04c27a9 (patch) | |
| tree | a67df41ebe39f360dd4005a715076aa328f21c9c /internal | |
| parent | ffa39a17f48ee9847cc85819d8134b5eb9482b77 (diff) | |
add dserver integration test for scheduled query
Diffstat (limited to 'internal')
| -rw-r--r-- | internal/server/continuous.go | 4 | ||||
| -rw-r--r-- | internal/server/scheduler.go | 4 |
2 files changed, 4 insertions, 4 deletions
diff --git a/internal/server/continuous.go b/internal/server/continuous.go index 93b3fcb..ac5c686 100644 --- a/internal/server/continuous.go +++ b/internal/server/continuous.go @@ -20,8 +20,8 @@ func newContinuous() *continuous { } func (c *continuous) start(ctx context.Context) { - dlog.Server.Info("Starting continuous job runner after 10s") - time.Sleep(time.Second * 10) + dlog.Server.Info("Starting continuous job runner after 2s") + time.Sleep(time.Second * 2) c.runJobs(ctx) } diff --git a/internal/server/scheduler.go b/internal/server/scheduler.go index 0ba65f7..36f167d 100644 --- a/internal/server/scheduler.go +++ b/internal/server/scheduler.go @@ -23,9 +23,9 @@ func newScheduler() *scheduler { } func (s *scheduler) start(ctx context.Context) { - dlog.Server.Info("Starting scheduled job runner after 10s") + dlog.Server.Info("Starting scheduled job runner after 2s") // First run after just 10s! - time.Sleep(time.Second * 10) + time.Sleep(time.Second * 2) s.runJobs(ctx) for { select { |
