| 118 | raise |
| 119 | |
| 120 | def init_reporter(self) -> None: |
| 121 | try: |
| 122 | max_retries = self.config.get("reporter", {}).get( |
| 123 | "push_data_max_retries", 30 |
| 124 | ) |
| 125 | self.reporter_agent = Reporter( |
| 126 | self.system, |
| 127 | self.cephx, |
| 128 | reporter_scheme=self.reporter_scheme, |
| 129 | reporter_hostname=self.mgr_host, |
| 130 | reporter_port=self.mgr_agent_port, |
| 131 | reporter_endpoint=self.reporter_endpoint, |
| 132 | max_retries=max_retries, |
| 133 | ) |
| 134 | self.reporter_agent.start() |
| 135 | except RuntimeError: |
| 136 | self.log.error("Can't initialize the reporter.") |
| 137 | raise |
| 138 | |
| 139 | def init_api(self) -> None: |
| 140 | try: |