Skip to content

Commit

Permalink
don't cleanup results directories, so that coophive RP can slurp them…
Browse files Browse the repository at this point in the history
… directly from disk instead of via terrible terrible bacalhau get IPFS path
  • Loading branch information
lukemarsden committed Mar 1, 2024
1 parent 5651cd8 commit f3d2c17
Showing 1 changed file with 5 additions and 6 deletions.
11 changes: 5 additions & 6 deletions pkg/compute/executor.go
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,6 @@ package compute
import (
"context"
"fmt"
"os"

"github.com/bacalhau-project/bacalhau/pkg/compute/store"
"github.com/bacalhau-project/bacalhau/pkg/executor"
Expand Down Expand Up @@ -193,11 +192,11 @@ func (e *BaseExecutor) Publish(ctx context.Context, execution store.Execution) (
return
}

log.Ctx(ctx).Debug().Msgf("Cleaning up result folder for %s: %s", execution.ID, resultFolder)
err = os.RemoveAll(resultFolder)
if err != nil {
log.Ctx(ctx).Error().Err(err).Msgf("failed to remove results folder at %s", resultFolder)
}
// log.Ctx(ctx).Debug().Msgf("Cleaning up result folder for %s: %s", execution.ID, resultFolder)
// err = os.RemoveAll(resultFolder)
// if err != nil {
// log.Ctx(ctx).Error().Err(err).Msgf("failed to remove results folder at %s", resultFolder)
// }

e.callback.OnPublishComplete(ctx, PublishResult{
ExecutionMetadata: NewExecutionMetadata(execution),
Expand Down

0 comments on commit f3d2c17

Please sign in to comment.