Change check_for_unprocessed_data_sets query

helium · May 7, 2024 · 65de9ab · 65de9ab
1 parent 94ce2a2
commit 65de9ab
Showing 1 changed file with 21 additions and 10 deletions.
diff --git a/mobile_verifier/src/boosting_oracles/data_sets.rs b/mobile_verifier/src/boosting_oracles/data_sets.rs
@@ -520,19 +520,30 @@ pub mod db {
         pool: &PgPool,
         period_end: DateTime<Utc>,
     ) -> sqlx::Result<bool> {
-        Ok(
-            sqlx::query_scalar(
-                "SELECT COUNT(*) > 0 FROM data_sets WHERE time_to_use <= $1 AND status != 'processed'",
-            )
-            .bind(period_end)
-            .fetch_one(pool)
-            .await?
+        Ok(sqlx::query_scalar(
+            "SELECT COUNT(*) > 0 FROM data_sets WHERE time_to_use <= $1 AND status != 'processed'",
+        )
+        .bind(period_end)
+        .fetch_one(pool)
+        .await?
             || sqlx::query_scalar(
-                "SELECT COUNT(*) > 0 from hexes where urbanized IS NULL OR footfall IS NULL OR landtype IS NULL"
+                r#"
+                SELECT COUNT(*) > 0 FROM coverage_objects
+                WHERE inserted_at < $1 AND uuid IN (
+                        SELECT
+                           DISTINCT uuid
+                        FROM
+                           hexes
+                        WHERE
+                           urbanized IS NULL
+                           OR footfall IS NULL
+                           OR landtype IS NULL
+                )
+                "#,
             )
+            .bind(period_end)
             .fetch_one(pool)
-            .await?
-        )
+            .await?)
     }
 }