parent
b9e9dd6c4b
commit
0a48d6a688
2 changed files with 1 additions and 2 deletions
|
|
@ -349,7 +349,7 @@ def db_lock(name, wait=True):
|
|||
# in the no-wait case, this could mean either that the row is already locked, or that
|
||||
# the lock does not exist, so we check
|
||||
query = "SELECT name FROM locks WHERE name=%(name)s"
|
||||
rows =_fetchMulti(query, data)
|
||||
rows = _fetchMulti(query, data)
|
||||
if rows:
|
||||
# the lock exists, but we did not acquire it
|
||||
return False
|
||||
|
|
|
|||
|
|
@ -9,7 +9,6 @@ import json
|
|||
import logging
|
||||
import random
|
||||
|
||||
import psycopg2
|
||||
from proton import Message, SSLDomain
|
||||
from proton.handlers import MessagingHandler
|
||||
from proton.reactor import Container
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue