Allow concurrent-ruby 1.3.x

Gemfile

@@ -8,7 +8,7 @@ gemspec
 gem 'json', '< 3.0' if Gem::Version.new(RUBY_VERSION) < Gem::Version.new('3.2')
 
 group :concurrent_ruby_ext, optional: ENV.key?('CI') && ENV['CONCURRENT_RUBY_EXT'] != 'true' do
-  gem 'concurrent-ruby-ext', '~> 1.1.3'
+  gem 'concurrent-ruby-ext', '~> 1.3.0'
 end
 
 group :pry, optional: ENV.key?('CI') do

dynflow.gemspec

@@ -21,9 +21,10 @@ Gem::Specification.new do |s|
   s.required_ruby_version = '>= 3.0.0'
 
   s.add_dependency "algebrick", '~> 0.7.0'
-  s.add_dependency "concurrent-ruby", '~> 1.1.3'
-  s.add_dependency "concurrent-ruby-edge", '~> 0.6.0'
+  s.add_dependency "concurrent-ruby", '>= 1.1.3', '< 2.0'
+  s.add_dependency "concurrent-ruby-edge", '~> 0.7.0'
   s.add_dependency "csv", "~> 3.1"
+  s.add_dependency 'logger'
   s.add_dependency "msgpack", '~> 1.3', '>= 1.3.3'
   s.add_dependency "multi_json"
   s.add_dependency "sequel", '>= 4.0.0'

lib/dynflow.rb

@@ -5,6 +5,7 @@
 require 'base64'
 require 'concurrent'
 require 'concurrent-edge'
+require 'logger'
 
 logger                          = Logger.new($stderr)
 logger.level                    = Logger::INFO

test/bats/sidekiq-orchestrator.bats

@@ -96,7 +96,10 @@ teardown() {
   wait_for 5 1 grep 'dynflow: Finished performing validity checks' "$(bg_output_file o1)"
 
   podman stop "$POSTGRES_CONTAINER_NAME"
-  wait_for 60 1 grep 'dynflow: World terminated, exiting.' "$(bg_output_file o1)"
+  # With concurrent-ruby 1.3 the persistence error surfaces after
+  # MAX_RETRIES polling rounds, which pushes the termination log past a
+  # 60s window (observed ~58s); allow a generous margin.
+  wait_for 180 1 grep 'dynflow: World terminated, exiting.' "$(bg_output_file o1)"
 }
 
 @test "active orchestrator can withstand temporary pg connection drop" {