Merge pull request #260 from alphagov/sengi/threadpool

Fix type error in configuring worker_threads.
alphagov · Apr 24, 2024 · 6ce03b3 · 6ce03b3
2 parents e24f5d0 + 0ea6983
commit 6ce03b3
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/lib/tasks/document_sync_worker.rake b/lib/tasks/document_sync_worker.rake
@@ -19,7 +19,7 @@ namespace :document_sync_worker do
     GovukMessageQueueConsumer::Consumer.new(
       queue_name: ENV.fetch("PUBLISHED_DOCUMENTS_MESSAGE_QUEUE_NAME"),
       processor: PublishingApiMessageProcessor.new,
-      worker_threads: ENV.fetch("PUBLISHED_DOCUMENTS_MESSAGE_QUEUE_THREADS", 1),
+      worker_threads: ENV.fetch("PUBLISHED_DOCUMENTS_MESSAGE_QUEUE_THREADS", 1).to_i,
     ).run
   rescue Interrupt
     Rails.logger.info("Stopping document sync worker (received interrupt)")