|
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