Setup standardized logging for a worker. Args: worker_type: Type of worker Returns: Configured logger instance
(worker_type: WorkerType)
| 86 | |
| 87 | @staticmethod |
| 88 | def setup_logging(worker_type: WorkerType) -> logging.Logger: |
| 89 | """Setup standardized logging for a worker. |
| 90 | |
| 91 | Args: |
| 92 | worker_type: Type of worker |
| 93 | |
| 94 | Returns: |
| 95 | Configured logger instance |
| 96 | """ |
| 97 | logging_config = WorkerRegistry.get_logging_config(worker_type) |
| 98 | |
| 99 | WorkerLogger.configure( |
| 100 | log_level=os.getenv("LOG_LEVEL", logging_config.get("log_level", "INFO")), |
| 101 | log_format=os.getenv( |
| 102 | "LOG_FORMAT", logging_config.get("log_format", "structured") |
| 103 | ), |
| 104 | worker_name=worker_type.to_worker_name(), |
| 105 | ) |
| 106 | |
| 107 | return WorkerLogger.get_logger(worker_type.to_worker_name()) |
| 108 | |
| 109 | @staticmethod |
| 110 | def setup_health_monitoring( |
no test coverage detected