Commit 7ad2396f authored by Fardale's avatar Fardale

Fix fd leak on the node

parent a898a217
......@@ -28,6 +28,10 @@ let run_computation (computation : computation) =
(name, Array.of_list (name :: computation.args))
and stdout = Lwt_io.read (Lwt_io.of_fd ~mode:Lwt_io.input read_stdout)
and stderr = Lwt_io.read (Lwt_io.of_fd ~mode:Lwt_io.input read_stderr) in
Lwt_unix.close read_stderr
>>= fun () ->
Lwt_unix.close read_stdout
>>= fun () ->
Lwt.return
{ id= computation.id
; stdout=
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment