(self, name=LOGGER_NAME)
| 167 | LOGGER_NAME = "a_logger_name" |
| 168 | |
| 169 | def init_logger(self, name=LOGGER_NAME): |
| 170 | stream = StringIO() |
| 171 | handler = logging.StreamHandler(stream) |
| 172 | formatter = logging.Formatter("%(levelname)s - %(message)s") |
| 173 | handler.setFormatter(formatter) |
| 174 | logger = logging.getLogger(name) |
| 175 | logger.setLevel(logging.INFO) |
| 176 | while len(logger.handlers) > 0: |
| 177 | logger.removeHandler(logger.handlers[-1]) |
| 178 | logger.addHandler(handler) |
| 179 | return handler, stream |
| 180 | |
| 181 | @parameterized.expand(TEST_COMPOSE_LAZY_ON_CALL_LOGGING_TEST_CASES) |
| 182 | def test_dataset_lazy_with_logging(self, compose_type, pipeline, lazy, expected): |
no outgoing calls
no test coverage detected