diff --git a/weed/worker/tasks/ec_vacuum/ec_vacuum_task.go b/weed/worker/tasks/ec_vacuum/ec_vacuum_task.go index 3ed7654c9..fedf98f67 100644 --- a/weed/worker/tasks/ec_vacuum/ec_vacuum_task.go +++ b/weed/worker/tasks/ec_vacuum/ec_vacuum_task.go @@ -53,7 +53,7 @@ func NewEcVacuumTask(id string, volumeID uint32, collection string, sourceNodes volumeID: volumeID, collection: collection, sourceNodes: sourceNodes, - cleanupGracePeriod: 1 * time.Minute, // 1 minute grace period for faster cleanup + cleanupGracePeriod: 1 * time.Minute, // 1 minute grace period for faster cleanup logic: NewEcVacuumLogic(), // Initialize business logic // sourceGeneration and targetGeneration will be determined during execution } @@ -83,13 +83,13 @@ func (t *EcVacuumTask) Execute(ctx context.Context, params *worker_pb.TaskParams t.targetGeneration = plan.TargetGeneration t.LogInfo("Vacuum plan created successfully", map[string]interface{}{ - "volume_id": plan.VolumeID, - "collection": plan.Collection, - "source_generation": plan.CurrentGeneration, - "target_generation": plan.TargetGeneration, - "cleanup_generations": plan.GenerationsToCleanup, - "nodes_involved": len(plan.SourceDistribution.Nodes), - "safety_checks": len(plan.SafetyChecks), + "volume_id": plan.VolumeID, + "collection": plan.Collection, + "source_generation": plan.CurrentGeneration, + "target_generation": plan.TargetGeneration, + "cleanup_generations": plan.GenerationsToCleanup, + "nodes_involved": len(plan.SourceDistribution.Nodes), + "safety_checks": len(plan.SafetyChecks), }) // Validate the plan is safe to execute