-
Notifications
You must be signed in to change notification settings - Fork 519
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 execution timing metrics for participation code #10158
Conversation
c2fdc8b
to
9cce464
Compare
6815c58
to
ee10edf
Compare
ee10edf
to
2b746ee
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.
Awesome! A few small nits, but looks great
@@ -2276,39 +2276,59 @@ let hash_transaction = | |||
in | |||
printf "%s\n" (Transaction_hash.to_base58_check hash)) | |||
|
|||
let humanize_graphql_error |
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.
Nice!
@@ -654,7 +660,8 @@ end = struct | |||
t.next_flush <- | |||
Some | |||
(Clock.Event.run_after max_wait | |||
(fun () -> | |||
(* <-- TODO: pretty sure this is a bug (this can infinitely delay flushes *) |
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.
Yea, looks like there should be an explicit
(if not (Strict_pipe.Writer.is_closed t.flush_w) then
Strict_pipe.Writer.write t.flush_w () );
after the Option.iter
. Doesn't need fixing in this PR though.
No description provided.