vlorentz · cf567031 · cf567031
--- a/rust/src/queries.rs
+++ b/rust/src/queries.rs
+            schema,
+            "c_in_d", // table name, for error messages
+            "cnt",
+            "dir",
+            node_ids,
+            None, // no limit
+        )
+        .await
+        .context("Could not query c_in_d")?;
+        tracing::trace!("Got c_in_d_stream");
+        tracing::debug!("Scan init metrics: {:#?}", scan_init_metrics);
+
+        Ok((scan_init_metrics, scan_metrics, c_in_d_stream))
+    }
+
+    /// Given a [`NodeId`], returns some records from the contents-in-revision table
--- a/rust/src/queries.rs
+++ b/rust/src/queries.rs
+        let limit = 1;
+        let (scan_init_metrics, scan_metrics, d_in_r_stream) = query_x_in_y_table(
+            &self.db.d_in_r,
+            schema,
+            "d_in_r", // table name, for error messages
+            "dir",
+            "revrel",
+            node_ids,
+            Some(limit),
+        )
+        .await
+        .context("Could not query d_in_r")?;
+        tracing::trace!("Got d_in_r_stream");
+        tracing::debug!("Scan init metrics: {:#?}", scan_init_metrics);
+
+        // Read batches of rows, stopping after the first one