def run_query()

in src/redash_stmo/query_runner/activedata.py [0:0]

• 17 lines of code
• 4 McCabe index (conditional complexity)

    def run_query(self, annotated_query, user):
        request = {}
        comment, request["sql"] = annotated_query.split("*/", 2)
        meta = request["meta"] = {}
        for kv in comment.strip()[2:].split(","):
            k, v = [s.strip() for s in kv.split(":")]
            meta[k] = v

        logger.debug("Send ActiveData a SQL query: %s", request["sql"])
        data = json.dumps(request, ensure_ascii=False)
        result = requests.post(self.configuration["host_url"] + "/sql", data=data)
        response = json.loads(result.content)

        if response.get("type") == "ERROR":
            cause = self.find_error_cause(response)
            return None, cause

        output = self.normalize_response(response)
        json_data = json.dumps(output, cls=JSONEncoder)
        return json_data, None