diff options
Diffstat (limited to 'internal/server/scheduler.go')
| -rw-r--r-- | internal/server/scheduler.go | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/internal/server/scheduler.go b/internal/server/scheduler.go index 1fdbeea..e75077e 100644 --- a/internal/server/scheduler.go +++ b/internal/server/scheduler.go @@ -84,7 +84,7 @@ func (s *scheduler) runJobs(ctx context.Context) { tmpOutfile := fmt.Sprintf("%s.tmp", outfile) query := fmt.Sprintf("%s outfile %s", job.Query, tmpOutfile) - client, err := clients.NewMaprClient(args, query) + client, err := clients.NewMaprClient(args, query, clients.CumulativeMode) if err != nil { logger.Error(fmt.Sprintf("Unable to create job job %s", job.Name), err) continue |