Support for schema qualified tables

[marcel-meyer]

Hi there,
I would like to place my queue table in a schema other than public.
When I set the table arg to a schema qualified table name, the following error occurs:

Traceback (most recent call last):
  File "worker.py", line 139, in <module>
    for job in queue:
  File "/Users/marcel/.pyenv/versions/2.7.15/lib/python2.7/site-packages/pq/__init__.py", line 86, in next
    return QueueIterator.__next__(self)
  File "/Users/marcel/.pyenv/versions/2.7.15/lib/python2.7/site-packages/pq/__init__.py", line 81, in __next__
    return self.queue.get(timeout=self.timeout)
  File "/Users/marcel/.pyenv/versions/2.7.15/lib/python2.7/site-packages/pq/__init__.py", line 176, in get
    cursor, block
  File "/Users/marcel/.pyenv/versions/2.7.15/lib/python2.7/site-packages/pq/utils.py", line 69, in wrapper
    cursor.execute("PREPARE %s AS\n%s" % (name, query), d)
psycopg2.ProgrammingError: syntax error at or near "."
LINE 1: PREPARE _pull_item_fsm.queue_test_fsm.queue AS

Is this possible?
Regards,
Marcel

[malthe]

Perhaps a decent workaround would be to issue this command on your connection (through an open cursor):

cursor.execute("SET search_path TO " + schema_name)

But it would be nice to have a schema option.

[riyadparvez]

Is there any update on this issue?

[ThibTrip]

Hello @riyadparvez it works on the master (as of writing this reply, version 1.9.1-dev) but not on the current PyPI version (1.9.0).
So if you clone the master and install with pip install . (or pip install -e . for editing the library) inside the cloned folder such a code will work (assuming the postgres schema already exists):

import pq

queue = pq.PQ(conn=conn, # some psycopg2 connection
              schema='queues', table='my_jobs')
queue.create()

Note: I was wondering the same thing and figured this out which is why I replied that late 😛