Skip to content

Commit

Permalink
resolved conflicts
Browse files Browse the repository at this point in the history
  • Loading branch information
isankadn committed Oct 18, 2024
1 parent 66ca640 commit 086a641
Showing 1 changed file with 0 additions and 10 deletions.
10 changes: 0 additions & 10 deletions historical_data/src/main.rs
Original file line number Diff line number Diff line change
Expand Up @@ -353,21 +353,11 @@ async fn process_tenant_historical_data(
}
};

<<<<<<< HEAD
let total_docs = mongo_collection
.count_documents(filter.clone(), None)
.await
.context("Failed to count documents in MongoDB")? as usize;
info!("Total documents to process: {}", total_docs);
=======
match mongo_collection.find(None, options).await {
Ok(mut cursor) => {
while let Some(result) = cursor.next().await {
// print!("tent info: {:?}", &tenant_config.name);
if let Ok(doc) = result {
let record_id = doc.get("_id").and_then(|id| id.as_object_id());
let statement = doc.get("statement").and_then(|s| s.as_document());
>>>>>>> e07455a (na)

let mut cursor = mongo_collection
.find(filter, None)
Expand Down

0 comments on commit 086a641

Please sign in to comment.