summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorschneefux <schneefux+commit@schneefux.xyz>2017-08-23 19:27:57 +0200
committerschneefux <schneefux+commit@schneefux.xyz>2017-08-23 19:27:57 +0200
commit1dfda21dcb1cdeb4ece768f7ed8f9e3c2cdd1d69 (patch)
treeecd9ddac59366909a16902748aeaaf8ea4608554
parente8d15d1f5bbcf1675e801214cf067bdae12255d2 (diff)
downloadanalyzer-1dfda21dcb1cdeb4ece768f7ed8f9e3c2cdd1d69.tar.gz
analyzer-1dfda21dcb1cdeb4ece768f7ed8f9e3c2cdd1d69.zip
don't open a db connection for telesucking if not configured
-rw-r--r--worker.py10
1 files changed, 8 insertions, 2 deletions
diff --git a/worker.py b/worker.py
index b06a6cd..741fbc8 100644
--- a/worker.py
+++ b/worker.py
@@ -135,7 +135,11 @@ def try_process():
return
logger.info("acking batch")
- db = Session(autocommit=True, autoflush=False) # ro session to get Telemetry URLs
+ db = None
+ if DOTELESUCKMATCH:
+ # ro session to get Telemetry URLs
+ db = Session(autocommit=True, autoflush=False)
+
for meth, prop, body in queue:
channel.basic_ack(meth.delivery_tag)
if DOCRUNCHMATCH:
@@ -159,7 +163,9 @@ def try_process():
}
))
- db.close()
+ if db is not None:
+ db.close()
+
queue = []