-
Notifications
You must be signed in to change notification settings - Fork 1.1k
Subgraph Composition: Cache blocks processed by firehose block stream #5631
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
Subgraph Composition: Cache blocks processed by firehose block stream #5631
Conversation
84f8044 to
d0fff45
Compare
fed212a to
10c5c95
Compare
856f3f4 to
deaa413
Compare
10c5c95 to
aed6de5
Compare
aed6de5 to
da218ec
Compare
4ad187b to
e44444f
Compare
da218ec to
317ce7a
Compare
|
|
||
| let start_time = Instant::now(); | ||
|
|
||
| let result = chain_store |
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.
Isn't this the exact responsibility of the Block Ingestor? I also don't think this should be in here because there will always be 1 stream per subgraph so this would be amplifying any write attempts or any backoffs, on top of adding more time to processing. Caching blocks is already done on the ingestor, if we need more data that's where I think it should go or if we need a healing mechanism it seems like something different.
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.
Agreed, Im closing this PR as upon evaluating, this caching is no longer required since the use of cached block ptr's which is done in a later PR
fae59fa to
4c0dc41
Compare
No description provided.