Skip to content
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

Avoid writer EOF until fast store complete #480

Merged

Conversation

chrisstaite-menlo
Copy link
Collaborator

@chrisstaite-menlo chrisstaite-menlo commented Dec 13, 2023

Description

Currently we send the EOF to the fast store and the requester at the same time. The bytestream_server drops the get_part future as soon as it receives the EOF which means that the fast store doesn't get time to sync and populate.

This is resolved by only sending the EOF to the requestor in the fast_slow_store once all of the futures have completed. The alternative is to spawn for the fast store or to complete the get_part future in bytestream_server, but this seems like the least heavy weight solution which doesn't require thought by the user.

Fixes #478

Type of change

Please delete options that are not relevant.

  • Bug fix (non-breaking change which fixes an issue)

How Has This Been Tested?

Testing with long latency link between two instances.

Checklist

  • Updated documentation if needed
  • Tests added/amended
  • bazel test //... passes locally
  • PR is contained in a single commit, using git amend see some docs

This change is Reviewable

Currently we send the EOF to the fast store and the requester at the same time.
The bytestream_server drops the get_part future as soon as it receives the EOF
which means that the fast store doesn't get time to sync and populate.

This is resolved by only sending the EOF to the requestor in the fast_slow_store
once all of the futures have completed.  The alternative is to spawn for the fast
store or to complete the get_part future in bytestream_server, but this seems like
the least heavy weight solution which doesn't require thought by the user.
Copy link
Member

@adam-singer adam-singer left a comment

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

:lgtm: , @allada for a second shipit

Reviewed 1 of 1 files at r1, 1 of 1 files at r2, all commit messages.
Reviewable status: :shipit: complete! all files reviewed, all discussions resolved (waiting on @allada)

@chrisstaite-menlo chrisstaite-menlo merged commit 2de8867 into TraceMachina:main Dec 14, 2023
16 of 21 checks passed
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

fast_slow does not persist to fast store when retrieved by bytestream_server
2 participants