diff options
Diffstat (limited to 'internal/executor/executor.go')
| -rw-r--r-- | internal/executor/executor.go | 8 |
1 files changed, 5 insertions, 3 deletions
diff --git a/internal/executor/executor.go b/internal/executor/executor.go index d25d3b4..51f468e 100644 --- a/internal/executor/executor.go +++ b/internal/executor/executor.go @@ -24,9 +24,10 @@ type Pool struct { store *storage.DB logger *slog.Logger - mu sync.Mutex - active int - resultCh chan *Result + mu sync.Mutex + active int + resultCh chan *Result + Questions *QuestionRegistry } // Result is emitted when a task execution completes. @@ -46,6 +47,7 @@ func NewPool(maxConcurrent int, runner Runner, store *storage.DB, logger *slog.L store: store, logger: logger, resultCh: make(chan *Result, maxConcurrent*2), + Questions: NewQuestionRegistry(), } } |