fixup! debug

Author: JamesWrigley

Project.toml

@@ -3,10 +3,14 @@ uuid = "fab6aee4-877b-4bac-a744-3eca44acbb6f"
 version = "1.0.0"
 
 [deps]
+Dates = "ade2ca70-3891-5945-98fb-dc099432e06a"
 Random = "9a3f8284-a2c9-5f02-9a11-845980a1fd5c"
 Serialization = "9e88b42a-f829-5b0c-bbe9-9e923198166b"
 Sockets = "6462fe0b-24de-5631-8697-dd941f90decc"
 
+[compat]
+Dates = "1.11.0"
+
 [extras]
 LibSSH = "00483490-30f8-4353-8aba-35b82f51f4d0"
 LinearAlgebra = "37e2e46d-f89d-539d-b4ee-838fcccc9c8e"

src/managers.jl

@@ -2,6 +2,8 @@
 
 # Built-in SSH and Local Managers
 
+import Dates: now
+
 struct SSHManager <: ClusterManager
     machines::Dict
 
@@ -767,7 +769,7 @@ function kill(manager::LocalManager, pid::Int, config::WorkerConfig; exit_timeou
 
         # Check to see if our child exited, and if not, send an actual kill signal
         if !process_exited(config.process)
-            @warn("Failed to gracefully kill worker $(pid), sending SIGQUIT")
+            @warn("$(now()) Failed to gracefully kill worker $(pid), sending SIGQUIT")
             kill(config.process, Base.SIGQUIT)
 
             sleep(term_timeout)

src/process_messages.jl

@@ -1,5 +1,7 @@
 # This file is a part of Julia. License is MIT: https://julialang.org/license
 
+import Dates: now
+
 # data stored by the owner of a remote reference
 def_rv_channel() = Channel(1)
 mutable struct RemoteValue
@@ -206,7 +208,7 @@ function message_handler_loop(r_stream::IO, w_stream::IO, incoming::Bool)
             end
             readbytes!(r_stream, boundary, length(MSG_BOUNDARY))
 
-            println("got msg: ", typeof(msg))
+            println("$(now()) got msg: ", typeof(msg))
             handle_msg(msg, header, r_stream, w_stream, version)
         end
     catch e