Check que_jobs exists before queueing jobs

bugsnag · Dec 15, 2023 · 01e6979 · 01e6979
1 parent c9d002c
commit 01e6979
Showing 1 changed file with 16 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,21 @@
 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
+    puts "~*~ que_jobs exists? ~*~ ", $connection.exec(query)[0]["que_jobs_exists"]
+
+    break if $connection.exec(query)[0]["que_jobs_exists"] == "t"
+
+    sleep 0.1
+  end
+end
+
 case ARGV[0]
 when "unhandled"
   UnhandledJob.enqueue