Bust cache

aws · Dec 4, 2024 · 75982f5 · 75982f5
1 parent 76b3cf8
commit 75982f5
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 4 deletions.
diff --git a/.github/workflows/ci.yml b/.github/workflows/ci.yml
@@ -57,6 +57,7 @@ jobs:
         with:
           ruby-version: ${{ matrix.ruby }}
           bundler-cache: true
+          cache-version: 0912834390128
 
       - name: Test
         run: bundle exec rake spec

diff --git a/lib/aws/rails/middleware/elastic_beanstalk_sqsd.rb b/lib/aws/rails/middleware/elastic_beanstalk_sqsd.rb
@@ -42,14 +42,14 @@ def shutdown(timeout = nil)
         private
 
         def init_executor
+          threads = Integer(ENV.fetch('AWS_PROCESS_BEANSTALK_WORKER_THREADS',
+                                      Concurrent.available_processor_count || Concurrent.processor_count))
+          puts "Running with threads: #{threads}"
           options = {
-            max_threads: Integer(Concurrent.available_processor_count || Concurrent.processor_count),
+            max_threads: threads,
             max_queue: 1,
             fallback_policy: :abort # Concurrent::RejectedExecutionError must be handled
           }
-          if ENV['AWS_PROCESS_BEANSTALK_WORKER_THREADS']
-            options[:max_threads] = Integer(ENV['AWS_PROCESS_BEANSTALK_WORKER_THREADS'])
-          end
           @executor = Concurrent::ThreadPoolExecutor.new(options)
           at_exit { shutdown }
         end