diff --git a/worker/zfs_hook.go b/worker/zfs_hook.go index 7e8f25e..785adef 100644 --- a/worker/zfs_hook.go +++ b/worker/zfs_hook.go @@ -3,6 +3,7 @@ package worker import ( "fmt" "os" + "os/user" "strings" "github.com/codeskyblue/go-sh" @@ -40,6 +41,14 @@ func (z *zfsHook) preJob() error { if err := sh.Command("sudo", "zfs", "set", "mountpoint="+workingDir, zfsDataset).Run(); err != nil { return err } + usr, err := user.Current() + if err != nil { + return err + } + logger.Infof("Chown %s to %s(%s)", workingDir, usr.Uid, usr.Username) + if err := sh.Command("sudo", "chown", usr.Uid, workingDir).Run(); err != nil { + return err + } } return nil }