|
1 | 1 | import datetime |
| 2 | +import logging |
2 | 3 | import os |
3 | 4 | import uuid |
4 | 5 | from typing import Any, AsyncGenerator, Callable, Generator, cast |
5 | 6 |
|
6 | 7 | import nest_asyncio |
7 | 8 | import pytest |
| 9 | +import structlog |
8 | 10 | import taskiq_fastapi |
9 | 11 | from alembic import command |
10 | 12 | from alembic.config import Config |
|
46 | 48 | nest_asyncio.apply() |
47 | 49 |
|
48 | 50 |
|
| 51 | +@pytest.fixture(autouse=True, scope="session") |
| 52 | +def _redirect_structlog_to_stdlib_and_mute() -> Generator[None, None, None]: |
| 53 | + """Setup logging for CI""" |
| 54 | + if os.getenv("CI", "false").lower() == "true": |
| 55 | + prev = structlog.get_config() |
| 56 | + |
| 57 | + structlog.configure( |
| 58 | + processors=[ |
| 59 | + structlog.stdlib.add_log_level, |
| 60 | + structlog.stdlib.PositionalArgumentsFormatter(), |
| 61 | + structlog.processors.format_exc_info, |
| 62 | + structlog.stdlib.ProcessorFormatter.wrap_for_formatter, |
| 63 | + ], |
| 64 | + logger_factory=structlog.stdlib.LoggerFactory(), |
| 65 | + wrapper_class=structlog.make_filtering_bound_logger(logging.WARNING), |
| 66 | + cache_logger_on_first_use=True, |
| 67 | + ) |
| 68 | + |
| 69 | + try: |
| 70 | + yield None |
| 71 | + finally: |
| 72 | + structlog.reset_defaults() |
| 73 | + structlog.configure(**prev) |
| 74 | + else: |
| 75 | + yield None |
| 76 | + |
| 77 | + |
49 | 78 | @pytest.fixture(scope="session") |
50 | 79 | async def global_engine(): |
51 | 80 | engine = build_engine(settings.database.url) |
@@ -85,6 +114,72 @@ def pytest_addoption(parser: Parser) -> None: |
85 | 114 | ) |
86 | 115 |
|
87 | 116 |
|
| 117 | +def configure() -> None: |
| 118 | + import logging.config |
| 119 | + |
| 120 | + import structlog |
| 121 | + |
| 122 | + timestamper = structlog.processors.TimeStamper(fmt="%Y-%m-%d %H:%M:%S") |
| 123 | + pre_chain = [ |
| 124 | + # Add the log level and a timestamp to the event_dict if the log entry |
| 125 | + # is not from structlog. |
| 126 | + structlog.stdlib.add_log_level, |
| 127 | + timestamper, |
| 128 | + ] |
| 129 | + |
| 130 | + logging.config.dictConfig( |
| 131 | + { |
| 132 | + "version": 1, |
| 133 | + "disable_existing_loggers": False, |
| 134 | + "formatters": { |
| 135 | + "plain": { |
| 136 | + "()": structlog.stdlib.ProcessorFormatter, |
| 137 | + "processor": structlog.dev.ConsoleRenderer(colors=False), |
| 138 | + "foreign_pre_chain": pre_chain, |
| 139 | + }, |
| 140 | + # "colored": { |
| 141 | + # "()": structlog.stdlib.ProcessorFormatter, |
| 142 | + # "processor": structlog.dev.ConsoleRenderer(colors=True), |
| 143 | + # "foreign_pre_chain": pre_chain, |
| 144 | + # }, |
| 145 | + }, |
| 146 | + "handlers": { |
| 147 | + "default": { |
| 148 | + "level": "ERROR", |
| 149 | + "class": "logging.StreamHandler", |
| 150 | + "formatter": "plain", # <---Change to "plain" |
| 151 | + }, |
| 152 | + "file": { |
| 153 | + "level": "ERROR", |
| 154 | + "class": "logging.handlers.WatchedFileHandler", |
| 155 | + "filename": "test.log", |
| 156 | + "formatter": "plain", |
| 157 | + }, |
| 158 | + }, |
| 159 | + "loggers": { |
| 160 | + "": { |
| 161 | + "handlers": ["default", "file"], |
| 162 | + "level": "ERROR", |
| 163 | + "propagate": True, |
| 164 | + }, |
| 165 | + }, |
| 166 | + } |
| 167 | + ) |
| 168 | + structlog.configure( |
| 169 | + processors=[ |
| 170 | + structlog.stdlib.add_log_level, |
| 171 | + structlog.stdlib.PositionalArgumentsFormatter(), |
| 172 | + timestamper, |
| 173 | + structlog.processors.StackInfoRenderer(), |
| 174 | + structlog.processors.format_exc_info, |
| 175 | + structlog.stdlib.ProcessorFormatter.wrap_for_formatter, |
| 176 | + ], |
| 177 | + logger_factory=structlog.stdlib.LoggerFactory(), |
| 178 | + wrapper_class=structlog.stdlib.BoundLogger, |
| 179 | + cache_logger_on_first_use=True, |
| 180 | + ) |
| 181 | + |
| 182 | + |
88 | 183 | def before(): |
89 | 184 | os.environ["PYTEST_APP_TESTING"] = "1" |
90 | 185 | for alembic_cfg in alembic_configs: |
|
0 commit comments