-
Notifications
You must be signed in to change notification settings - Fork 1.5k
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
Add resharding integration tests #5069
Conversation
bfb7fd8
to
387ddc9
Compare
fe17f33
to
a8832b9
Compare
Handle `ReshardingScaleDown` replica state
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.
Some remarks, happy to resolve them in a separate PR so we can merge this one.
abort_resharding, | ||
]) | ||
|
||
# Finish resharding |
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.
Since we're also checking we cannot reapply, shall we also assert that we cannot finish resharding a second time?
|
||
peer_api_uris, _peer_dirs, _bootstrap_uri = start_cluster(tmp_path, 3, None, extra_env=env) | ||
# TODO: Wait for/check... *what*? 🤔 |
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.
We cannot check this.
Maybe we want to assert the collection is properly deleted, I don't think we can do more. So lets remove the todo.
@pytest.mark.parametrize("direction, peers", [("up", 3), ("down", 3)]) | ||
def test_resharding_forward(tmp_path: pathlib.Path, direction: Literal["up", "down"], peers: int): |
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.
Maybe we can also parameterize the number of shards/replicas (if that isn't too expensive)
Co-authored-by: Tim Visée <tim+github@visee.me>
This PR (re)implements resharding integration tests, because existing ones are not applicable anymore, since we moved resharding driver into cluster-manager.
All Submissions:
dev
branch. Did you create your branch fromdev
?New Feature Submissions:
cargo +nightly fmt --all
command prior to submission?cargo clippy --all --all-features
command?Changes to Core Features: