diff options
Diffstat (limited to 'weed/worker/tasks/task_logger.go')
| -rw-r--r-- | weed/worker/tasks/task_logger.go | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/weed/worker/tasks/task_logger.go b/weed/worker/tasks/task_logger.go index e9c06c35c..430513184 100644 --- a/weed/worker/tasks/task_logger.go +++ b/weed/worker/tasks/task_logger.go @@ -127,7 +127,7 @@ func NewTaskLogger(taskID string, taskType types.TaskType, workerID string, para Status: "started", Progress: 0.0, VolumeID: params.VolumeID, - Server: params.Server, + Server: getServerFromSources(params.TypedParams.Sources), Collection: params.Collection, CustomData: make(map[string]interface{}), LogFilePath: logFilePath, @@ -149,7 +149,7 @@ func NewTaskLogger(taskID string, taskType types.TaskType, workerID string, para logger.Info("Task logger initialized for %s (type: %s, worker: %s)", taskID, taskType, workerID) logger.LogWithFields("INFO", "Task parameters", map[string]interface{}{ "volume_id": params.VolumeID, - "server": params.Server, + "server": getServerFromSources(params.TypedParams.Sources), "collection": params.Collection, }) |