Commit 2e964852 authored by vicotor's avatar vicotor

add log

parent c4bd5828
...@@ -70,11 +70,15 @@ func newManagerClient(endpoint string) (omanager.NodeManagerServiceClient, error ...@@ -70,11 +70,15 @@ func newManagerClient(endpoint string) (omanager.NodeManagerServiceClient, error
} }
func DispatchTask(worker Worker, task *odysseus.TaskContent) error { func DispatchTask(worker Worker, task *odysseus.TaskContent) error {
l := log.WithField("task-uuid", task.TaskUuid)
l.WithFields(log.Fields{
"worker": worker.workerid,
"managerList": worker.managers,
}).Debug("dispatch task to worker")
for _, manager := range worker.managers { for _, manager := range worker.managers {
client, err := newManagerClient(manager) client, err := newManagerClient(manager)
if err != nil { if err != nil {
log.WithFields(log.Fields{ l.WithFields(log.Fields{
"manager": manager, "manager": manager,
"error": err, "error": err,
}).Error("connect to manager failed") }).Error("connect to manager failed")
...@@ -85,7 +89,7 @@ func DispatchTask(worker Worker, task *odysseus.TaskContent) error { ...@@ -85,7 +89,7 @@ func DispatchTask(worker Worker, task *odysseus.TaskContent) error {
TaskData: task, TaskData: task,
}) })
if err != nil { if err != nil {
log.WithFields(log.Fields{ l.WithFields(log.Fields{
"manager": manager, "manager": manager,
"error": err, "error": err,
}).Error("dispatch to manager failed") }).Error("dispatch to manager failed")
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment