-
Notifications
You must be signed in to change notification settings - Fork 178
RUST-1859 Sync bulk write spec tests #1106
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
RUST-1859 Sync bulk write spec tests #1106
Conversation
@@ -57,6 +57,8 @@ impl<'a> OperationWithDefaults for Insert<'a> { | |||
const NAME: &'static str = "insert"; | |||
|
|||
fn build(&mut self, description: &StreamDescription) -> Result<Command<Self::Command>> { | |||
self.inserted_ids.clear(); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Caught by a retryable writes test, we were adding duplicates here upon retry
src/operation/distinct.rs
Outdated
}; | ||
|
||
if !self.query.is_empty() { | ||
body.insert("query", self.query.clone()); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
One of the new crud tests expects this field to be present even if the query is empty
@@ -40,14 +39,6 @@ impl PartialBulkWriteResult { | |||
} | |||
} | |||
|
|||
#[tokio::test(flavor = "multi_thread")] | |||
async fn run_unified() { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
These are now run in crud::run_unified
643931e
to
de3c7c8
Compare
This also pulls in some unified test conversions (RUST-1866, RUST-1863).