diff options
Diffstat (limited to 'weed/worker/tasks/erasure_coding/register.go')
| -rw-r--r-- | weed/worker/tasks/erasure_coding/register.go | 5 |
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 |