def exec_queries()

in libmozdata/connection.py [0:0]
47 lines of code
8 McCabe index (conditional complexity)

    def exec_queries(self, queries=None):
        """Set and exec some queries

        Args:
            queries (Optional[Query]): the queries to exec
        """
        if queries:
            self.queries = queries

        if self.queries:
            if isinstance(self.queries, Query):
                self.queries = [self.queries]

            header = self.get_header()
            auth = self.get_auth()

            for query in self.queries:
                cb = self.__get_cb(query)
                if query.params:
                    if isinstance(query.params, dict):
                        self.results.append(
                            self.session.get(
                                query.url,
                                params=query.params,
                                headers=header,
                                auth=auth,
                                verify=self.VERIFY_SSL,
                                timeout=self.TIMEOUT,
                                hooks={"response": cb},
                            )
                        )
                    else:
                        for p in query.params:
                            self.results.append(
                                self.session.get(
                                    query.url,
                                    params=p,
                                    headers=header,
                                    auth=auth,
                                    verify=self.VERIFY_SSL,
                                    timeout=self.TIMEOUT,
                                    hooks={"response": cb},
                                )
                            )
                else:
                    self.results.append(
                        self.session.get(
                            query.url,
                            headers=header,
                            auth=auth,
                            verify=self.VERIFY_SSL,
                            timeout=self.TIMEOUT,
                            hooks={"response": cb},
                        )
                    )