Check que_jobs exists before queueing jobs

bugsnag · Dec 15, 2023 · 0ddd889 · 0ddd889
1 parent c9d002c
commit 0ddd889
Showing 1 changed file with 14 additions and 0 deletions.
diff --git 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