Skip to content

Commit f69a618

Browse files
committed
Removes unnecessary log messages
1 parent 9987b07 commit f69a618

2 files changed

Lines changed: 1 addition & 4 deletions

File tree

internal/workflow/task_data.go

Lines changed: 0 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -6,7 +6,6 @@ import (
66
"errors"
77
"fmt"
88
clientv3 "go.etcd.io/etcd/client/v3"
9-
"log"
109
"time"
1110

1211
"github.com/serverledge-faas/serverledge/utils"
@@ -68,7 +67,6 @@ func (td *TaskData) Save(reqId ReqId, task TaskId) error {
6867
}
6968
// saves the json object into etcd
7069
key := getTaskDataEtcdKey(reqId, task)
71-
log.Printf("Saving PD on etcd with key: %s\n", key)
7270

7371
_, err = cli.Put(ctx, key, string(payload))
7472
if err != nil {
@@ -86,7 +84,6 @@ func RetrievePartialData(reqId ReqId, task TaskId) (*TaskData, error) {
8684
ctx, cancel := context.WithTimeout(context.Background(), 10*time.Second)
8785
defer cancel()
8886
key := getTaskDataEtcdKey(reqId, task)
89-
log.Printf("Retrieving partial data with key: %s\n", key)
9087
getResponse, err := cli.Get(ctx, key)
9188
if err != nil {
9289
utils.TryEtcdReconnection()

internal/workflow/workflow.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -412,7 +412,7 @@ func (wflow *Workflow) savePartialDataForReadyTasks(requestId ReqId, progress *P
412412
return fmt.Errorf("Could not save partial data: %v", err)
413413
}
414414
} else {
415-
log.Printf("PD not available locally for %s; they might be on Etcd already...", prev)
415+
// PD not available locally; they might be on Etcd already...
416416
}
417417

418418
handledTasks[prev] = true

0 commit comments

Comments
 (0)