async def _send_query_request(output_channel: connection.TextWriter, query_text: str) -> None:
    query_message = json.dumps(['Query', query_text])
    LOG.debug(f'Sending `{log.truncate(query_message, 400)}`')
    (await output_channel.write(f'''{query_message}
'''))
async def _send_query_request(output_channel: connection.TextWriter, query_text: str) -> None:
    query_message = json.dumps(['Query', query_text])
    LOG.debug(f'Sending `{log.truncate(query_message, 400)}`')
    (await output_channel.write(f'{query_message}
'))