Return connections
This commit is contained in:
parent
6053aaa829
commit
f20630564d
1 changed files with 2 additions and 0 deletions
|
@ -66,6 +66,8 @@ def pg_conn_notify():
|
||||||
conns.append(conn)
|
conns.append(conn)
|
||||||
log.debug("Waiting for notifications on channel {}".format(channel))
|
log.debug("Waiting for notifications on channel {}".format(channel))
|
||||||
|
|
||||||
|
return conns
|
||||||
|
|
||||||
def pg_wait_for_pkg(conns, callback):
|
def pg_wait_for_pkg(conns, callback):
|
||||||
readable, writable, exceptional = select.select(conns,[],[])
|
readable, writable, exceptional = select.select(conns,[],[])
|
||||||
|
|
||||||
|
|
Loading…
Reference in a new issue