-
Notifications
You must be signed in to change notification settings - Fork 14
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
feat: support batch publish #140
Conversation
eaad36d
to
a8e1056
Compare
a8e1056
to
30fb3eb
Compare
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.
Very nice!
src/agent/state/exporter.rs
Outdated
publish_program_key, | ||
updates, | ||
)?; | ||
updates = unsupported_updates; |
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.
I think the fallback might fail because we also change the batch size, so maybe a simpler way can be just to crash? I think it highly depends on our upgrade process.
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.
Changed to return error on missing feed_index.
src/agent/state/exporter.rs
Outdated
)?); | ||
} | ||
} | ||
let mut data = vec![1]; |
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.
Please add a comment that this is the instruction id and the wire format in general.
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.
Now it imports instruction types from the program crate.
Cargo.toml
Outdated
@@ -56,6 +56,8 @@ tracing-opentelemetry = "0.24.0" | |||
opentelemetry = "0.23.0" | |||
opentelemetry_sdk = { version = "0.23.0", features = ["rt-tokio"]} | |||
opentelemetry-otlp = { version = "0.16.0" } | |||
pyth-price-publisher = { git = "https://github.com/pyth-network/pyth-crosschain", branch = "add-publisher-program" } |
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.
let's publish this package too. also bump the agent version.
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.
Done.
9335bcd
to
801b902
Compare
a3593c3
to
7fea315
Compare
publish_program_key
field to the config