airflow/contrib/hooks/salesforce_hook.py
def make_query(self, query):
        """
        Make a query to Salesforce.

        :param query: The query to make to Salesforce.
        :type query: str
        :return: The query result.
        :rtype: dict
        """
        conn = self.get_conn()

        self.log.info("Querying for all objects")
        query_results = conn.query_all(query)

        self.log.info("Received results: Total size: %s; Done: %s",
                      query_results['totalSize'], query_results['done'])

        return query_results
def make_query(self, query):
        conn = self.get_conn()

        self.log.info("Querying for all objects")
        query_results = conn.query_all(query)

        self.log.info("Received results: Total size: %s; Done: %s",
                      query_results['totalSize'], query_results['done'])

        return query_results
def make_query ( self , query ) : conn = self . get_conn ( ) self . log . info ( "Querying for all objects" ) query_results = conn . query_all ( query ) self . log . info ( "Received results: Total size: %s; Done: %s" , query_results [ 'totalSize' ] , query_results [ 'done' ] ) return query_results
Make a query to Salesforce.

        :param query: The query to make to Salesforce.
        :type query: str
        :return: The query result.
        :rtype: dict
Make a query to Salesforce .