From eb9c8d4ae7f8fb7e65f912ff4838c7737b5487d0 Mon Sep 17 00:00:00 2001 From: Paul Buetow Date: Fri, 3 Jul 2020 12:15:59 +0100 Subject: refactor mapr client --- internal/server/continuous.go | 20 +------------------- 1 file changed, 1 insertion(+), 19 deletions(-) (limited to 'internal/server/continuous.go') diff --git a/internal/server/continuous.go b/internal/server/continuous.go index bdb4079..cf89cdd 100644 --- a/internal/server/continuous.go +++ b/internal/server/continuous.go @@ -4,7 +4,6 @@ import ( "context" "fmt" "os" - "strconv" "strings" "time" @@ -45,26 +44,9 @@ func (s *continuous) runJobs(ctx context.Context) { continue } - hour, err := strconv.Atoi(time.Now().Format("15")) - if err != nil { - logger.Error(job.Name, "Unable to create job job", err) - continue - } - - if hour < job.TimeRange[0] || hour >= job.TimeRange[1] { - logger.Debug(job.Name, "Not running job out of time range") - continue - } - files := fillDates(job.Files) outfile := fillDates(job.Outfile) - _, err = os.Stat(outfile) - if !os.IsNotExist(err) { - logger.Debug(job.Name, "Not running job as outfile already exists", outfile) - continue - } - servers := strings.Join(job.Servers, ",") if servers == "" { servers = config.Server.SSHBindAddress @@ -84,7 +66,7 @@ func (s *continuous) 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.NonCumulativeMode) if err != nil { logger.Error(fmt.Sprintf("Unable to create job job %s", job.Name), err) continue -- cgit v1.2.3