From c1d049718279b659892d6fdbea65cd17c9519d1f Mon Sep 17 00:00:00 2001 From: Ken Hibino Date: Fri, 6 Dec 2019 22:29:40 -0800 Subject: [PATCH] Remove debug log --- internal/rdb/rdb.go | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) diff --git a/internal/rdb/rdb.go b/internal/rdb/rdb.go index 654e230..7ef8515 100644 --- a/internal/rdb/rdb.go +++ b/internal/rdb/rdb.go @@ -97,7 +97,6 @@ func (r *RDB) Dequeue(timeout time.Duration) (*TaskMessage, error) { if err != nil { return nil, fmt.Errorf("could not unmarshal %v to json: %v", data, err) } - fmt.Printf("[DEBUG] perform task %+v from %s\n", msg, defaultQ) return &msg, nil } @@ -196,7 +195,6 @@ func (r *RDB) forward(from string) error { return msgs `) now := float64(time.Now().Unix()) - res, err := script.Run(r.client, []string{from, allQueues, defaultQ}, now).Result() - fmt.Printf("[DEBUG] got %d tasks from %q\n", len(res.([]interface{})), from) + _, err := script.Run(r.client, []string{from, allQueues, defaultQ}, now).Result() return err -} \ No newline at end of file +}