reservation assignments

Author: max-ostapenko

definitions/declarations/chrome-ux-report.js

@@ -30,9 +30,3 @@ FROM ${ctx.ref(database, 'materialized', 'device_summary')}
 |> WHERE cnt_devices != 3 OR cnt_ranks != 10
 |> SELECT "Table data doesn't match 3 unique devices and 10 ranks" AS error_message
 `)
-
-declare({
-  database,
-  schema: 'experimental',
-  name: 'global'
-})

definitions/declarations/httparchive.js

@@ -40,3 +40,22 @@ ORDER BY cnt_pages DESC
     name: table
   })
 )
+
+operate('create_reservation_assignment')
+  .tags(['crawl_complete'])
+  .queries(ctx => `
+CREATE ASSIGNMENT
+\`httparchive.region-us.retrospective-reprocessing.pipeline\`
+OPTIONS (
+  assignee = 'projects/httparchive',
+  job_type = 'QUERY')
+`)
+
+operate('drop_reservation_assignment', {
+  dependencies: ['requests_10k']
+})
+  .tags(['crawl_complete'])
+  .queries(ctx => `
+DROP ASSIGNMENT IF EXISTS
+\`httparchive.region-us.retrospective-reprocessing.pipeline\`
+`)

definitions/output/crawl/pages.js

@@ -47,7 +47,8 @@ publish('pages', {
     technologies: 'Technologies detected at runtime (see https://www.wappalyzer.com/)',
     metadata: 'Additional metadata about the test'
   },
-  tags: ['crawl_complete']
+  tags: ['crawl_complete'],
+  dependencies: ['create_reservation_assignment']
 }).preOps(ctx => `
 DELETE FROM ${ctx.self()}
 WHERE date = '${constants.currentMonth}' AND

definitions/output/crawl/parsed_css.js

@@ -7,7 +7,8 @@ publish('parsed_css', {
     clusterBy: ['client', 'is_root_page', 'rank', 'page'],
     requirePartitionFilter: true
   },
-  tags: ['crawl_complete']
+  tags: ['crawl_complete'],
+  dependencies: ['create_reservation_assignment']
 }).preOps(ctx => `
 DELETE FROM ${ctx.self()}
 WHERE date = '${constants.currentMonth}'

definitions/output/crawl/requests.js

@@ -36,7 +36,8 @@ publish('requests', {
     },
     response_body: 'Text-based response body'
   },
-  tags: ['crawl_complete']
+  tags: ['crawl_complete'],
+  dependencies: ['create_reservation_assignment']
 }).preOps(ctx => `
 FOR client_value IN (SELECT * FROM UNNEST(['desktop', 'mobile']) AS client) DO
   FOR is_root_page_value IN (SELECT * FROM UNNEST([TRUE, FALSE]) AS is_root_page) DO