diff --git a/runtime/task.go b/runtime/task.go index 0c909d3..c1be83e 100644 --- a/runtime/task.go +++ b/runtime/task.go @@ -134,6 +134,7 @@ func (t *Task) Run(ctx context.Context, task *runnerv1.Task) error { defer func() { _ = reporter.Close(lastWords) }() + reporter.RunDaemon() reporter.Logf("received task %v of job %v", task.Id, task.Context.Fields["job"].GetStringValue())