lee/backrest
1
0
Fork 0
mirror of https://github.com/garethgeorge/backrest.git synced 2025-12-13 01:05:48 +00:00
Code Issues Actions 1 Packages Projects Releases Wiki Activity

feat: track long running generic commands in the oplog (#516)

Browse Source
This commit is contained in:
Gareth
2024-10-12 13:38:28 -07:00
committed by GitHub
parent d7704cf057
commit 28c31720f2
23 changed files with 642 additions and 445 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
internal/orchestrator/taskrunnerimpl.go
View File

@@ -104,10 +104,9 @@ func (t *taskRunnerImpl) ExecuteHooks(ctx context.Context, events []v1.Hook_Cond
}
for _, task := range hookTasks {
st, _ := task.Next(time.Now(), t)
st.Task = task
if err := t.OpLog().Add(st.Op); err != nil {
return fmt.Errorf("%v: %w", task.Name(), err)
st, err := t.orchestrator.CreateUnscheduledTask(task, tasks.TaskPriorityDefault, time.Now())
if err != nil {
return fmt.Errorf("creating task for hook: %w", err)
}
if err := t.orchestrator.RunTask(ctx, st); hook.IsHaltingError(err) {
var cancelErr *hook.HookErrorRequestCancel