aboutsummaryrefslogtreecommitdiff
path: root/weed/worker/tasks/erasure_coding/register.go
diff options
context:
space:
mode:
authorChris Lu <chrislusf@users.noreply.github.com>2025-08-09 21:47:29 -0700
committerGitHub <noreply@github.com>2025-08-09 21:47:29 -0700
commit25bbf4c3d44b1c8a9aa4980e37ed399ec249f771 (patch)
treeaabb2ce3c6f55e4cf1e26ce2b6989086c17830bc /weed/worker/tasks/erasure_coding/register.go
parent3ac2a2e22d863753a6b568596fbe9d76d03023b5 (diff)
downloadseaweedfs-25bbf4c3d44b1c8a9aa4980e37ed399ec249f771.tar.xz
seaweedfs-25bbf4c3d44b1c8a9aa4980e37ed399ec249f771.zip
Admin UI: Fetch task logs (#7114)
* show task details * loading tasks * task UI works * generic rendering * rendering the export link * removing placementConflicts from task parameters * remove TaskSourceLocation * remove "Server ID" column * rendering balance task source * sources and targets * fix ec task generation * move info * render timeline * simplified worker id * simplify * read task logs from worker * isValidTaskID * address comments * Update weed/worker/tasks/balance/execution.go Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com> * Update weed/worker/tasks/erasure_coding/ec_task.go Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com> * Update weed/worker/tasks/task_log_handler.go Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com> * fix shard ids * plan distributing shard id * rendering planned shards in task details * remove Conflicts * worker logs correctly * pass in dc and rack * task logging * Update weed/admin/maintenance/maintenance_queue.go Co-authored-by: gemini-code-assist[bot] <176961590+gemini-code-assist[bot]@users.noreply.github.com> * display log details * logs have fields now * sort field keys * fix link * fix collection filtering * avoid hard coded ec shard counts --------- Co-authored-by: Copilot <175728472+Copilot@users.noreply.github.com> Co-authored-by: gemini-code-assist[bot] <176961590+gemini-code-assist[bot]@users.noreply.github.com>
Diffstat (limited to 'weed/worker/tasks/erasure_coding/register.go')
-rw-r--r--weed/worker/tasks/erasure_coding/register.go5
1 files changed, 4 insertions, 1 deletions
diff --git a/weed/worker/tasks/erasure_coding/register.go b/weed/worker/tasks/erasure_coding/register.go
index 883aaf965..e574e0033 100644
--- a/weed/worker/tasks/erasure_coding/register.go
+++ b/weed/worker/tasks/erasure_coding/register.go
@@ -42,9 +42,12 @@ func RegisterErasureCodingTask() {
if params == nil {
return nil, fmt.Errorf("task parameters are required")
}
+ if len(params.Sources) == 0 {
+ return nil, fmt.Errorf("at least one source is required for erasure coding task")
+ }
return NewErasureCodingTask(
fmt.Sprintf("erasure_coding-%d", params.VolumeId),
- params.Server,
+ params.Sources[0].Node, // Use first source node
params.VolumeId,
params.Collection,
), nil