dashboard/modules/log/log_head.py
async def _list_logs(self, node_id_query: str, filters: List[str]):
        """
        Helper function to list the logs by querying each agent
        on each cluster via gRPC.
        """
        response = {}
        tasks = []
        for node_id, grpc_stub in self._stubs.items():
            if node_id_query is None or node_id_query == node_id:

                async def coro():
                    reply = await grpc_stub.ListLogs(
                        reporter_pb2.ListLogsRequest(), timeout=log_consts.GRPC_TIMEOUT
                    )
                    response[node_id] = self._list_logs_single_node(
                        reply.log_files, filters
                    )

                tasks.append(coro())
        await asyncio.gather(*tasks)
        return response

        Helper function to list the logs by querying each agent
        on each cluster via gRPC.
        
Helper function to list the logs by querying each agent
on each cluster via gRPC.
Helper function to list the logs by querying each agent on each cluster via gRPC .
async def _list_logs(self, node_id_query: str, filters: List[str]):
        response = {}
        tasks = []
        for node_id, grpc_stub in self._stubs.items():
            if node_id_query is None or node_id_query == node_id:
                async def coro():
                    reply = await grpc_stub.ListLogs(
                        reporter_pb2.ListLogsRequest(), timeout=log_consts.GRPC_TIMEOUT
                    )
                    response[node_id] = self._list_logs_single_node(
                        reply.log_files, filters
                    )
                tasks.append(coro())
        await asyncio.gather(*tasks)
        return response
async def _list_logs ( self , node_id_query : str , filters : List [ str ] ) : response = { } tasks = [ ] for node_id , grpc_stub in self . _stubs . items ( ) : if node_id_query is None or node_id_query == node_id : async def coro ( ) : reply = await grpc_stub . ListLogs ( reporter_pb2 . ListLogsRequest ( ) , timeout = log_consts . GRPC_TIMEOUT ) response [ node_id ] = self . _list_logs_single_node ( reply . log_files , filters ) tasks . append ( coro ( ) ) await asyncio . gather ( * tasks ) return response
Helper function to list the logs by querying each agent
on each cluster via gRPC.
Helper function to list the logs by querying each agent on each cluster via gRPC .
"""
        Helper function to list the logs by querying each agent
        on each cluster via gRPC.
        """
self
node_id_query
str
filters
List[str]