summaryrefslogtreecommitdiff
path: root/internal
diff options
context:
space:
mode:
authorPaul Buetow <paul@buetow.org>2021-10-29 12:13:55 +0300
committerPaul Buetow <paul@buetow.org>2021-10-29 12:13:55 +0300
commita5f0c021f2caecf9adfec65583c915b6c04c27a9 (patch)
treea67df41ebe39f360dd4005a715076aa328f21c9c /internal
parentffa39a17f48ee9847cc85819d8134b5eb9482b77 (diff)
add dserver integration test for scheduled query
Diffstat (limited to 'internal')
-rw-r--r--internal/server/continuous.go4
-rw-r--r--internal/server/scheduler.go4
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 {