def retrieve_metrics()

in main_flow.py [0:0]

• 10 lines of code
• 1 McCabe index (conditional complexity)

    def retrieve_metrics(self):
        '''
        Retrieves search term sanitization aggregation data from BigQuery,
        then checks that they have not varied outside appreciable tolerances
        in the past X days ('X' is a window set for each metric)
        '''
        print("Retrieving Data Validation Metrics Now...")

        from data_validation import retrieve_data_validation_metrics

        self.validation_df = retrieve_data_validation_metrics(self.data_validation_origin)
        self.next(self.record_results)