(self, aid: int, log_level=logging.INFO)
| 49 | @ray.remote |
| 50 | class LogActor: |
| 51 | def __init__(self, aid: int, log_level=logging.INFO): |
| 52 | assert os.environ.get(LOG_DIR_ENV_VAR) is not None, "LOG_DIR_ENV_VAR must be set" |
| 53 | self.logger = get_logger(f"actor_{aid}", in_ray_actor=True, level=log_level) |
| 54 | self.logger.info(f"LogActor {aid} initialized ") |
| 55 | self.logger.debug(f"LogActor {aid} initialized") |
| 56 | self.aid = aid |
| 57 | self.actor = ActorInActor.remote(f"actor_{aid}", log_level) |
| 58 | ray.get(self.actor.__ray_ready__.remote()) |
| 59 | |
| 60 | def log_info(self, message: str): |
| 61 | self.logger.info(f"LogActor {self.aid} info: {message}") |
nothing calls this directly
no test coverage detected