Fix passing field through ExecutorAPI

Signed-off-by: JamesMurkin <jamesmurkin@hotmail.com>
armadaproject · Jun 19, 2024 · 51c6d84 · 51c6d84
1 parent 6f37311
commit 51c6d84
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/internal/scheduler/api.go b/internal/scheduler/api.go
@@ -69,6 +69,7 @@ func NewExecutorApi(producer pulsar.Producer,
 		jobRepository:             jobRepository,
 		executorRepository:        executorRepository,
 		allowedPriorities:         allowedPriorities,
+		maxEventsPerPulsarMessage: maxEventsPerPulsarMessage,
 		maxPulsarMessageSizeBytes: maxPulsarMessageSizeBytes,
 		nodeIdLabel:               nodeIdLabel,
 		priorityClassNameOverride: priorityClassNameOverride,