def _exception_hook(exc_type, exc_value, exc_traceback):
if exc_type.__name__ == 'StreamerError':
node = exc_value.node
error = exc_value.error
# node.graph.draw(attention=node)
logger.error('Error occured when running streamers. See graph')
exc_type = type(error)
exc_value = error
elif exc_type.__name__ == 'StreamerConnError':
node1 = exc_value.src_node
node2 = exc_value.tgt_node
error = exc_value.error
# node1.graph.draw(attention=[node1, node2])
logger.error('Error occured when running streamers. See graph')
exc_type = type(error)
exc_value = error
sys.__excepthook__(exc_type, exc_value, exc_traceback)
评论列表
文章目录