def mirror_stdout_stderr(self):
        """Simple STDOUT and STDERR mirroring used by _init_jupyter"""
        # TODO: Ideally we could start collecting logs without pushing
        fs_api = self._api.get_file_stream_api()
        io_wrap.SimpleTee(sys.stdout, streaming_log.TextStreamPusher(
            fs_api, OUTPUT_FNAME, prepend_timestamp=True))
        io_wrap.SimpleTee(sys.stderr, streaming_log.TextStreamPusher(
            fs_api, OUTPUT_FNAME, prepend_timestamp=True, line_prepend='ERROR'))
def mirror_stdout_stderr ( self ) : fs_api = self . _api . get_file_stream_api ( ) io_wrap . SimpleTee ( sys . stdout , streaming_log . TextStreamPusher ( fs_api , OUTPUT_FNAME , prepend_timestamp = True ) ) io_wrap . SimpleTee ( sys . stderr , streaming_log . TextStreamPusher ( fs_api , OUTPUT_FNAME , prepend_timestamp = True , line_prepend = 'ERROR' ) )
Simple STDOUT and STDERR mirroring used by _init_jupyter