diff --git a/features/fixtures/que/app/enqueue-job.rb b/features/fixtures/que/app/enqueue-job.rb index 0589274c..45eff66b 100644 --- a/features/fixtures/que/app/enqueue-job.rb +++ b/features/fixtures/que/app/enqueue-job.rb @@ -1,5 +1,19 @@ require_relative "setup-que" +query = <<-SQL +SELECT EXISTS ( + SELECT FROM pg_tables WHERE tablename = 'que_jobs' +) AS que_jobs_exists +SQL + +Timeout::timeout(10) do + loop do + break if $connection.exec(query)[0]["que_jobs_exists"] == "t" + + sleep 0.1 + end +end + case ARGV[0] when "unhandled" UnhandledJob.enqueue