Skip to content

EventStreamHandler

autogen.logger.logger_utils.EventStreamHandler #

EventStreamHandler(stream=None)

Bases: StreamHandler

Source code in autogen/logger/logger_utils.py 
68
69
def __init__(self, stream=None):  # type: ignore [no-untyped-def]
    super().__init__(stream or sys.stdout)

emit #

emit(record)
Source code in autogen/logger/logger_utils.py 
71
72
73
74
75
76
77
78
79
80
81
def emit(self, record: logging.LogRecord) -> None:
    try:
        msg = self.format(record)
        end = getattr(record, _END_KEY, "\n")
        stream = self.stream
        stream.write(msg)
        stream.write(end)
        if getattr(record, _FLUSH_KEY, True):
            self.flush()
    except Exception:
        self.handleError(record)