Files
yatm/executor/job_archive_start.go
2023-09-26 16:47:06 +08:00

16 lines
389 B
Go

package executor
import (
"context"
"github.com/samuelncui/yatm/entity"
)
func (e *Executor) startArchive(ctx context.Context, job *Job) error {
return e.Submit(ctx, job, &entity.JobNextParam{Param: &entity.JobNextParam_Archive{
Archive: &entity.JobArchiveNextParam{Param: &entity.JobArchiveNextParam_WaitForTape{
WaitForTape: &entity.JobArchiveWaitForTapeParam{},
}},
}})
}