(self, record: logging.LogRecord)
| 27 | super().__init__(fmt, datefmt) |
| 28 | |
| 29 | def format(self, record: logging.LogRecord) -> str: |
| 30 | msg = super().format(record) |
| 31 | if record.message: |
| 32 | prefix = msg.split(record.message)[0] |
| 33 | msg = msg.replace("\n", f"\r\n{prefix}") |
| 34 | return msg |
| 35 | |
| 36 | |
| 37 | # Process global logger for Ray actors, since Ray may create multiple processes and we want to reuse the logger instance within the same process. |
no outgoing calls