def main()

in backfill/2024-11-06-metrics-pings-metric-labels-over-max-length/insert_to_prod.py [0:0]


def main():
    with open("stable_metrics.yaml") as stream:
        stable_schema = yaml.safe_load(stream)

    with open("backfill_metrics.yaml") as stream:
        backfill_schema = yaml.safe_load(stream)

    select_expression = generate_compatible_select_expression(backfill_schema, stable_schema)

    with open("insert.sql", "w") as f:
        insert_statement = f"""
        INSERT INTO
          `moz-fx-data-shared-prod.firefox_desktop_stable.metrics_v1`
        {select_expression}
        FROM
          `moz-fx-data-backfill-1.firefox_desktop_stable.metrics_v1`
        WHERE
          DATE(submission_timestamp) > "2024-10-01"
        """
        f.write(insert_statement)