Bug with a branch node worker

[Cybersurfer]

I'm trying to setup root->branch replication using this guide (https://github.com/markokr/skytools/blob/master/doc/howto/londiste3_cascaded_rep_howto.txt)

Everything goes well until launching branch-node worker. It crashes immediately after startup 2013-01-17 17:00:15,052 5567 DEBUG init 2013-01-17 17:00:15,057 5568 DEBUG Connect 'db' to 'dbname=db2 host=127.0.0.1 port=5431 [...] ' 2013-01-17 17:00:15,062 5568 DEBUG exec_cmd: select * from pgq_node.get_consumer_state('replik a', 'londiste_db2') 2013-01-17 17:00:15,065 5568 DEBUG 100 Ok 2013-01-17 17:00:15,066 5568 DEBUG exec_cmd: select * from pgq_node.set_consumer_error('replik a', 'londiste_db2', NULL) 2013-01-17 17:00:15,066 5568 DEBUG 100 None 2013-01-17 17:00:15,067 5568 DEBUG Connect '_provider_db' to 'dbname=db1 host=127.0.0.1 [... ]' 2013-01-17 17:00:15,068 5568 DEBUG exec_cmd: select * from pgq_node.get_node_info('replika') 2013-01-17 17:00:15,074 5568 DEBUG 100 Ok 2013-01-17 17:00:15,086 5568 INFO pgq.maint_operations is installed 2013-01-17 17:00:15,087 5568 DEBUG Sync tables 2013-01-17 17:00:15,088 5568 DEBUG New event: id=1 / type=pgq.location-info / data=slave / ext ra1=replika 2013-01-17 17:00:15,088 5568 DEBUG got cascade event: pgq.location-info(slave) 2013-01-17 17:00:15,090 5568 DEBUG New event: id=2 / type=pgq.location-info / data=slave / ext ra1=replika 2013-01-17 17:00:15,090 5568 DEBUG got cascade event: pgq.location-info(slave) 2013-01-17 17:00:15,091 5568 DEBUG Connect 'db' to 'dbname=db2 host=127.0.0.1 port=5431 [...]' 2013-01-17 17:00:15,096 5568 DEBUG exec_cmd: select * from pgq_node.set_consumer_error('replika', 'londiste_db2', 'Writing to queue disabled') 2013-01-17 17:00:15,099 5568 DEBUG 100 Consumer londiste_db2 error = Writing to queue disabled 2013-01-17 17:00:15,099 5568 ERROR Job londiste_db2 got error on connection 'db': Writing to queue disabled. Query: select pgq.current_event_table('replika') Traceback (most recent call last): File "/usr/lib/pymodules/python2.7/skytools-3.0/skytools/scripting.py", line 563, in run_func_safely return func() File "/usr/lib/pymodules/python2.7/skytools-3.0/pgq/cascade/consumer.py", line 199, in work return Consumer.work(self) File "/usr/lib/pymodules/python2.7/skytools-3.0/pgq/consumer.py", line 280, in work self._launch_process_batch(db, batch_id, ev_list) File "/usr/lib/pymodules/python2.7/skytools-3.0/pgq/consumer.py", line 309, in _launch_process_batch self.process_batch(db, batch_id, list) File "/usr/lib/pymodules/python2.7/skytools-3.0/pgq/cascade/consumer.py", line 175, in process_batch self.finish_remote_batch(src_db, dst_db, tick_id) File "/usr/lib/pymodules/python2.7/skytools-3.0/pgq/cascade/worker.py", line 362, in finish_remote_batch self.flush_events(dst_curs) File "/usr/lib/pymodules/python2.7/skytools-3.0/pgq/cascade/worker.py", line 419, in flush_events bulk_insert_events(dst_curs, self.ev_buf, flds, st.target_queue) File "/usr/lib/pymodules/python2.7/skytools-3.0/pgq/producer.py", line 31, in bulk_insert_events curs.execute(q, [queue_name]) File "/usr/lib/python2.7/dist-packages/psycopg2/extras.py", line 123, in execute return _cursor.execute(self, query, vars) InternalError: Writing to queue disabled

Both DBs are on the same server

Test server configuration: Ubuntu 12.04 LTS PostgreSQL 9.1.5 Skytools 3.1.2 Python 2.7.3 psycopg2 2.4.5

Ini files:

cat pgqd.ini [pgqd] database_list = db1,db2 logfile = /tmp/pgqd.log pidfile = /tmp/pgqd.pid

cat db1.ini [londiste3] job_name = londiste_db1 db = dbname=db1 host=127.0.0.1 port=5431 password=***** queue_name = replika logfile = /tmp/%(job_name)s.log pidfile = /tmp/%(job_name)s.pid

pgq_autocommit = 1 pgq_lazy_fetch = 0

cat db2.ini [londiste3] job_name = londiste_db2 db = dbname=db2 host=127.0.0.1 port=5431 password=***** queue_name = replika logfile = /tmp/%(job_name)s.log pidfile = /tmp/%(job_name)s.pid

pgq_autocommit = 1 pgq_lazy_fetch = 0

[Cybersurfer]

It seems to be an issue with pgbouncer (1.4.2) Direct connection works fine

[Cybersurfer]

Got same error with pgbouncer 1.5.4