def _run_statistics_sql()

in opmon/monitoring.py [0:0]

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

    def _run_statistics_sql(self, submission_date):
        table_name = f"{self.normalized_slug}_statistics_v{SCHEMA_VERSIONS['statistic']}"
        self.bigquery.execute(
            self._get_statistics_sql(submission_date=submission_date),
            destination_table=f"{table_name}${submission_date:%Y%m%d}",
            clustering=["build_id"],
            time_partitioning="submission_date",
            write_disposition=bigquery.job.WriteDisposition.WRITE_TRUNCATE,
            dataset=self.derived_dataset,
        )