async def METHOD_NAME(self, monitor_info):
    client = self.get_client(
        LogsQueryClient, self.get_credential(LogsQueryClient, is_async=True))
    async with client:
        requests = [
            LogsBatchQuery(
                query="AzureActivity | summarize count()",
                timespan=timedelta(hours=1),
                workspace_id=monitor_info['workspace_id']
            ),
            LogsBatchQuery(
                query= """bad query | take 10""",
                timespan=(datetime(2021, 6, 2), timedelta(days=1)),
                workspace_id=monitor_info['workspace_id']
            ),
            LogsBatchQuery(
                query= """let Weight = 92233720368547758;
                range x from 1 to 3 step 1
                | summarize percentilesw(x, Weight * 100, 50)""",
                workspace_id=monitor_info['workspace_id'],
                timespan=(datetime(2021, 6, 2), datetime(2021, 6, 3)),
                include_statistics=True
            ),
        ]
        responses = await client.query_batch(requests)
        r1, r2, r3 = responses[0], responses[1], responses[2]
        assert r1.__class__ == LogsQueryResult
        assert r2.__class__ == LogsQueryError
        assert r3.__class__ == LogsQueryPartialResult