File tree Expand file tree Collapse file tree 2 files changed +4
-2
lines changed
Expand file tree Collapse file tree 2 files changed +4
-2
lines changed Original file line number Diff line number Diff line change @@ -147,7 +147,7 @@ def run():
147147 if args .watcher :
148148 # Run in Watcher mode
149149 logger .debug ('Starting in Watcher mode' )
150- watcher = MonetaWatcher ()
150+ watcher = MonetaWatcher (local_config [ 'nodename' ] )
151151 watcher .run ()
152152 sys .exit (0 )
153153
Original file line number Diff line number Diff line change 2525class MonetaWatcher (object ):
2626 """ Watch a process and send updates back to the manager. """
2727
28- def __init__ (self ):
28+ def __init__ (self , nodename ):
2929 """ Constructor """
3030
3131 self .task = None
3232 self .taskconfig = {}
3333 self .processid = None
3434 self .manager = None
35+ self .nodename = nodename
3536
3637 self .report = {}
3738 self .exec_greenlet = None
@@ -82,6 +83,7 @@ def handle_clean_exit():
8283 # Initial report
8384 start = datetime .utcnow ().replace (tzinfo = dateutil .tz .tzutc ())
8485 self .report .update ({
86+ "node" : self .nodename ,
8587 "task" : self .task ,
8688 "pid" : getpid (),
8789 "start_time" : start ,
You can’t perform that action at this time.
0 commit comments