remove exception raised for testing

This commit is contained in:
Noah Levitt 2014-04-07 11:45:54 -07:00
parent aacb886b62
commit 89e41e7c82

View File

@ -156,9 +156,6 @@ class Umbra:
with conn.Consumer(url_queue, callbacks=[self.fetch_url]) as consumer: with conn.Consumer(url_queue, callbacks=[self.fetch_url]) as consumer:
import socket import socket
while not self.amqp_stop.is_set(): while not self.amqp_stop.is_set():
import random
if random.randrange(0, 30) == 0:
raise BaseException("test exception!")
try: try:
conn.drain_events(timeout=0.5) conn.drain_events(timeout=0.5)
except socket.timeout: except socket.timeout: