Creates, starts, and returns a `SubprocessServerDataIngester`.
(self)
| 397 | mimetypes.add_type("text/html", ".html") |
| 398 | |
| 399 | def _start_subprocess_data_ingester(self): |
| 400 | """Creates, starts, and returns a `SubprocessServerDataIngester`.""" |
| 401 | flags = self.flags |
| 402 | server_binary = server_ingester.get_server_binary() |
| 403 | ingester = server_ingester.SubprocessServerDataIngester( |
| 404 | server_binary=server_binary, |
| 405 | logdir=flags.logdir, |
| 406 | reload_interval=flags.reload_interval, |
| 407 | channel_creds_type=flags.grpc_creds_type, |
| 408 | samples_per_plugin=flags.samples_per_plugin, |
| 409 | extra_flags=shlex.split(flags.extra_data_server_flags), |
| 410 | ) |
| 411 | ingester.start() |
| 412 | return ingester |
| 413 | |
| 414 | def _make_data_ingester(self): |
| 415 | """Determines the right data ingester, starts it, and returns it.""" |
no test coverage detected