lib/que/poller.rb
def cleanup(connection)
        connection.execute <<-SQL
          DROP FUNCTION pg_temp.que_highest_remaining_priority(jsonb);
          DROP FUNCTION pg_temp.lock_and_update_priorities(jsonb, que_jobs);
          DROP TYPE pg_temp.que_query_result;
        SQL
      end
# Manage some temporary infrastructure (specific to the connection) that
# we'll use for polling. These could easily be created permanently in a
# migration, but that'd require another migration if we wanted to tweak
# them later.
Manage some temporary infrastructure (specific to the connection) that
we'll use for polling. These could easily be created permanently in a
migration, but that'd require another migration if we wanted to tweak
them later.
Manage some temporary infrastructure ( specific to the connection ) that we ' ll use for polling . These could easily be created permanently in a migration but that ' d require another migration if we wanted to tweak them later .
def cleanup(connection)
        connection.execute <<-SQL
          DROP FUNCTION pg_temp.que_highest_remaining_priority(jsonb);
          DROP FUNCTION pg_temp.lock_and_update_priorities(jsonb, que_jobs);
          DROP TYPE pg_temp.que_query_result;
        SQL
      end
def cleanup ( connection ) connection . execute <<-SQL 
          DROP FUNCTION pg_temp.que_highest_remaining_priority(jsonb);
          DROP FUNCTION pg_temp.lock_and_update_priorities(jsonb, que_jobs);
          DROP TYPE pg_temp.que_query_result;
         SQL end
Manage some temporary infrastructure (specific to the connection) that
we'll use for polling.
Manage some temporary infrastructure ( specific to the connection ) that we ' ll use for polling .
connection