async def _run(self, server_start_options: 'PyreServerStartOptions') -> None:
    start_arguments = server_start_options.start_arguments
    local_root = start_arguments.base_arguments.relative_local_root
    socket_path = server_connection.get_default_socket_path(project_root=Path(start_arguments.base_arguments.global_root), relative_local_root=(Path(local_root) if local_root else None))
    strict_default = server_start_options.strict_default
    type_queries_enabled = ((server_start_options.ide_features is not None) and server_start_options.ide_features.is_hover_enabled())
    while True:
        query = (await self.state.queries.get())
        if isinstance(query, TypesQuery):
            if type_queries_enabled:
                (await self._update_types_for_paths([query.path], socket_path))
        elif isinstance(query, TypeCoverageQuery):
            (await self._handle_type_coverage_query(query, strict_default, socket_path))
async def _run(self, server_start_options: 'PyreServerStartOptions') -> None:
    start_arguments = server_start_options.start_arguments
    local_root = start_arguments.base_arguments.relative_local_root
    socket_path = server_connection.get_default_socket_path(project_root=Path(start_arguments.base_arguments.global_root), relative_local_root=(Path(local_root) if local_root else None))
    strict_default = server_start_options.strict_default
    type_queries_enabled = ((server_start_options.ide_features is not None) and server_start_options.ide_features.is_hover_enabled())
    while True:
        query = (await self.state.queries.get())
        if isinstance(query, TypesQuery):
            if type_queries_enabled:
                (await self._update_types_for_paths([query.path], socket_path))
        elif isinstance(query, TypeCoverageQuery):
            (await self._handle_type_coverage_query(query, strict_default, socket_path))