From 1dfda21dcb1cdeb4ece768f7ed8f9e3c2cdd1d69 Mon Sep 17 00:00:00 2001 From: schneefux Date: Wed, 23 Aug 2017 19:27:57 +0200 Subject: don't open a db connection for telesucking if not configured --- worker.py | 10 ++++++++-- 1 file changed, 8 insertions(+), 2 deletions(-) (limited to 'worker.py') 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 = [] -- cgit v1.3.1