Git-Mirrors/brozzler
1
0
Fork 0
mirror of https://github.com/internetarchive/brozzler.git synced 2025-02-24 00:29:53 -05:00
Code Issues Actions Packages Projects Releases Wiki Activity

properly handle socket.error from amqp conn.drain_events (was previously diagnosed as error starting browser)

Browse Source
This commit is contained in:
Noah Levitt 2014-11-03 11:54:10 -08:00
parent f40bd39e1a
commit ab86426475
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
umbra/controller.py
View File

@ -117,6 +117,9 @@ class AmqpBrowserController:
break # out of "while True" to acquire another browser break # out of "while True" to acquire another browser
except socket.timeout: except socket.timeout:
pass pass
except socket.error:
self.logger.error("problem consuming messages from AMQP, will try reconnecting after active browsing finishes", exc_info=True)
self._reconnect_requested = True
if self._consumer_stop.is_set() or time.time() - start >= timeout or self._reconnect_requested: if self._consumer_stop.is_set() or time.time() - start >= timeout or self._reconnect_requested:
browser.stop() browser.stop()