Fix CI: remove unneeded open
s
This commit is contained in:
parent
536e64d93f
commit
5400984c36
@ -354,7 +354,6 @@ module Make(Proto: Registered_protocol.T)(Arg: ARG): T = struct
|
|||||||
| Error errors ->
|
| Error errors ->
|
||||||
refused (Operation.hash op) op errors
|
refused (Operation.hash op) op errors
|
||||||
| Ok op ->
|
| Ok op ->
|
||||||
let open Preapply_result in
|
|
||||||
Prevalidation.apply_operation state op >>= function
|
Prevalidation.apply_operation state op >>= function
|
||||||
| Applied (new_acc_validation_state, _) ->
|
| Applied (new_acc_validation_state, _) ->
|
||||||
if pv.applied_count <= 2000 (* this test is a quick fix while we wait for the new mempool *)
|
if pv.applied_count <= 2000 (* this test is a quick fix while we wait for the new mempool *)
|
||||||
@ -463,7 +462,6 @@ module Make(Proto: Registered_protocol.T)(Arg: ARG): T = struct
|
|||||||
dir := RPC_directory.gen_register !dir
|
dir := RPC_directory.gen_register !dir
|
||||||
(Proto_services.S.Mempool.monitor_operations RPC_path.open_root)
|
(Proto_services.S.Mempool.monitor_operations RPC_path.open_root)
|
||||||
begin fun { applied ; refusals = refused ; branch_refusals = branch_refused ; branch_delays = branch_delayed ; operation_stream } params () ->
|
begin fun { applied ; refusals = refused ; branch_refusals = branch_refused ; branch_delays = branch_delayed ; operation_stream } params () ->
|
||||||
let open Preapply_result in
|
|
||||||
let op_stream, stopper = Lwt_watcher.create_stream operation_stream in
|
let op_stream, stopper = Lwt_watcher.create_stream operation_stream in
|
||||||
(* Convert ops *)
|
(* Convert ops *)
|
||||||
let map_op op =
|
let map_op op =
|
||||||
|
Loading…
Reference in New Issue
Block a user