def METHOD_NAME():
    with socket.socket(socket.AF_INET, socket.SOCK_STREAM) as s:
        s.settimeout(30)
        s.connect((CLICKHOUSE_HOST, CLICKHOUSE_PORT))
        sendHello(s)
        receiveHello(s)
        sendQuery(s, "select 1", {"replication_alter_partitions_sync": 1})
        # external tables
        sendEmptyBlock(s)
        while readResponse(s) is not None:
            pass
        s.close()
    print("OK")