@@ -77,17 +77,6 @@ def generate_per_app_id(
7777 parallelism = 8 ,
7878 id_token = None ,
7979 ):
80- # Get the app ID from the baseline_table name.
81- # This is what `common.py` also does.
82- app_id = re .sub (r"_stable\..+" , "" , baseline_table )
83- app_id = "." .join (app_id .split ("." )[1 :])
84-
85- # Skip any not-allowed app.
86- if app_id in ConfigLoader .get (
87- "generate" , "glean_usage" , "events_monitoring" , "skip_apps" , fallback = []
88- ):
89- return
90-
9180 tables = table_names_from_baseline (baseline_table , include_project_id = False )
9281
9382 init_filename = f"{ self .target_table_id } .materialized_view.sql"
@@ -107,6 +96,12 @@ def generate_per_app_id(
10796 if dataset == app_dataset ["bq_dataset_family" ]
10897 ][0 ]
10998
99+ # Skip any not-allowed app.
100+ if app_name in ConfigLoader .get (
101+ "generate" , "glean_usage" , "events_monitoring" , "skip_apps" , fallback = []
102+ ):
103+ return
104+
110105 if app_name in events_table_overwrites :
111106 events_tables = events_table_overwrites [app_name ]
112107 else :
@@ -192,6 +187,10 @@ def generate_across_apps(
192187 aggregate_table = "event_monitoring_aggregates_v1"
193188 target_view_name = "_" .join (self .target_table_id .split ("_" )[:- 1 ])
194189
190+ skipped_apps = ConfigLoader .get (
191+ "generate" , "glean_usage" , "events_monitoring" , "skip_apps" , fallback = []
192+ )
193+
195194 events_table_overwrites = ConfigLoader .get (
196195 "generate" , "glean_usage" , "events_monitoring" , "events_tables" , fallback = {}
197196 )
@@ -220,7 +219,7 @@ def generate_across_apps(
220219 event_tables_per_dataset [dataset ] = events_table_overwrites [
221220 app_name
222221 ]
223- else :
222+ elif app_name not in skipped_apps :
224223 v1_name = [
225224 app_dataset ["v1_name" ]
226225 for _ , app in get_app_info ().items ()
0 commit comments