From a7c1018f473402695ce93e283430bd55ecd2de32 Mon Sep 17 00:00:00 2001 From: navjot Date: Mon, 12 Oct 2020 23:17:05 +0530 Subject: [PATCH] fixed CQ for src.class_singleWorker module --- src/class_singleWorker.py | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/src/class_singleWorker.py b/src/class_singleWorker.py index c8640e49..b0cbfb69 100644 --- a/src/class_singleWorker.py +++ b/src/class_singleWorker.py @@ -557,10 +557,10 @@ class singleWorker(StoppableThread): continue if not sqlExecute( - '''UPDATE sent SET status='doingbroadcastpow' ''' - ''' WHERE ackdata=? AND status='broadcastqueued' ''' - ''' AND folder='sent' ''', - ackdata): + '''UPDATE sent SET status='doingbroadcastpow' ''' + ''' WHERE ackdata=? AND status='broadcastqueued' ''' + ''' AND folder='sent' ''', + ackdata): continue # At this time these pubkeys are 65 bytes long @@ -1298,7 +1298,7 @@ class singleWorker(StoppableThread): newStatus = 'msgsent' # wait 10% past expiration sleepTill = int(time.time() + TTL * 1.1) - au = sqlExecute( + sqlExecute( '''UPDATE sent SET msgid=?, status=?, retrynumber=?, ''' ''' sleeptill=?, lastactiontime=? WHERE ackdata=? AND folder='sent' ''', inventoryHash, newStatus, retryNumber + 1,