Fix health check.

Author: ioquatix

lib/async/job/adapter/active_job/dispatcher.rb

@@ -62,9 +62,12 @@ def keys
 					end
 
 					def status_string
-						@queues.map do |name, queue|
-							if queue.respond_to?(:status_string)
-								"#{name} (#{queue.status_string})"
+						self.keys.map do |name|
+							queue = @queues[name]
+							server = queue&.server
+							
+							if server&.respond_to?(:status_string)
+								"#{name} #{server.status_string}"
 							else
 								name
 							end

lib/async/job/adapter/active_job/service.rb

@@ -29,17 +29,17 @@ def setup(container)
 
 							instance.ready!
 
-							if health_check_timeout
-								Async(transient: true) do
-									while true
-										instance.name = "#{self.name} (#{dispatcher.status_string})"
-										sleep(health_check_timeout / 2)
-										instance.ready!
+							Sync do |task|
+								if health_check_timeout
+									Async(transient: true) do
+										while true
+											instance.name = "#{self.name} (#{dispatcher.status_string})"
+											sleep(health_check_timeout / 2)
+											instance.ready!
+										end
 									end
 								end
-							end
-							
-							Sync do |task|
+								
 								barrier = Async::Barrier.new
 
 								# Start all the named queues:

releases.md

@@ -1,5 +1,9 @@
 # Releases
 
+## Unreleased
+
+  - Fix health check.
+
 ## v0.16.3
 
   - Actually use `container_options`. I have been working too much.