import traceback\r
import sys\r
from AutoGen.DataPipe import MemoryDataPipe\r
+import logging\r
+\r
def clearQ(q):\r
try:\r
while True:\r
q.get_nowait()\r
except Empty:\r
pass\r
-import logging\r
\r
class LogAgent(threading.Thread):\r
def __init__(self,log_q,log_level,log_file=None):\r
\r
def clearQueue(self):\r
taskq = self.autogen_workers[0].module_queue\r
+ logq = self.autogen_workers[0].log_q\r
clearQ(taskq)\r
clearQ(self.feedback_q)\r
-\r
+ clearQ(logq)\r
def TerminateWorkers(self):\r
self.error_event.set()\r
def kill(self):\r