|
1 | 1 | use std::collections::{HashMap, HashSet};
|
2 | 2 | use std::fs;
|
3 | 3 | use std::ops::RangeInclusive;
|
| 4 | +use std::str::FromStr; |
4 | 5 | use std::sync::{Arc, LazyLock};
|
5 | 6 | use std::time::Instant;
|
6 | 7 |
|
@@ -288,19 +289,25 @@ impl SiteCtxt {
|
288 | 289 | pub async fn enqueue_master_commits(&self) {
|
289 | 290 | let conn = self.conn().await;
|
290 | 291 | let master_commits = &self.get_master_commits().commits;
|
| 292 | + // TODO; delete at some point in the future |
| 293 | + let cutoff: chrono::DateTime<Utc> = |
| 294 | + chrono::DateTime::from_str("2025-06-01T00:00:00.000Z").unwrap(); |
291 | 295 |
|
292 | 296 | for master_commit in master_commits {
|
293 |
| - let pr = master_commit.pr.unwrap_or(0); |
294 |
| - let benchmark = BenchmarkRequest::create_master( |
295 |
| - &master_commit.sha, |
296 |
| - Some(&master_commit.parent_sha), |
297 |
| - pr, |
298 |
| - master_commit.time, |
299 |
| - BenchmarkRequestStatus::Queued, |
300 |
| - "", |
301 |
| - "", |
302 |
| - ); |
303 |
| - conn.insert_benchmark_request(&benchmark).await; |
| 297 | + // We don't want to add masses of obsolete data |
| 298 | + if master_commit.time >= cutoff { |
| 299 | + let pr = master_commit.pr.unwrap_or(0); |
| 300 | + let benchmark = BenchmarkRequest::create_master( |
| 301 | + &master_commit.sha, |
| 302 | + Some(&master_commit.parent_sha), |
| 303 | + pr, |
| 304 | + master_commit.time, |
| 305 | + BenchmarkRequestStatus::Queued, |
| 306 | + "", |
| 307 | + "", |
| 308 | + ); |
| 309 | + conn.insert_benchmark_request(&benchmark).await; |
| 310 | + } |
304 | 311 | }
|
305 | 312 | }
|
306 | 313 | }
|
|
0 commit comments