Skip to content

Commit 16b2ea3

Browse files
committed
parallel: port to 5.2.1 + core v0.17
1 parent 38bfa18 commit 16b2ea3

File tree

2 files changed

+6
-5
lines changed

2 files changed

+6
-5
lines changed

src/lib/parallel/dune

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -7,7 +7,7 @@
77
async_rpc_kernel
88
async
99
core
10-
rpc_parallel
10+
rpc_parallel.unauthenticated
1111
async.async_rpc
1212
core_kernel)
1313
(preprocess

src/lib/parallel/parallel.ml

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1,11 +1,12 @@
11
open Core
22
open Async
3+
open Rpc_parallel_unauthenticated
34

45
let initialized = ref false
56

67
let worker_command_name = "parallel-worker"
78

8-
let worker_command = Rpc_parallel.Expert.worker_command
9+
let worker_command = Expert.worker_command
910

1011
let init_master () =
1112
if not !initialized then (
@@ -14,7 +15,7 @@ let init_master () =
1415
~send_every:(Time_ns.Span.of_sec 10.) ~timeout:(Time_ns.Span.of_min 15.)
1516
()
1617
in
17-
Rpc_parallel.Expert.start_master_server_exn
18-
~rpc_handshake_timeout:(Time.Span.of_min 10.) ~rpc_heartbeat_config
19-
~worker_command_args:[ worker_command_name ] () ;
18+
Expert.start_master_server_exn
19+
~rpc_handshake_timeout:(Time_float.Span.of_min 10.)
20+
~rpc_heartbeat_config ~worker_command_args:[ worker_command_name ] () ;
2021
initialized := true )

0 commit comments

Comments
 (0)