diff options
| author | schneefux <schneefux+commit@schneefux.xyz> | 2017-08-23 19:27:57 +0200 |
|---|---|---|
| committer | schneefux <schneefux+commit@schneefux.xyz> | 2017-08-23 19:27:57 +0200 |
| commit | 1dfda21dcb1cdeb4ece768f7ed8f9e3c2cdd1d69 (patch) | |
| tree | ecd9ddac59366909a16902748aeaaf8ea4608554 | |
| parent | e8d15d1f5bbcf1675e801214cf067bdae12255d2 (diff) | |
| download | analyzer-1dfda21dcb1cdeb4ece768f7ed8f9e3c2cdd1d69.tar.gz analyzer-1dfda21dcb1cdeb4ece768f7ed8f9e3c2cdd1d69.zip | |
don't open a db connection for telesucking if not configured
| -rw-r--r-- | worker.py | 10 |
1 files changed, 8 insertions, 2 deletions
@@ -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 = [] |
