@@ -88,6 +88,7 @@ def deserialize(self, proc_file, restart=False):
8888 if mode == constants .MODE_SHELL :
8989 if restart :
9090 register .add_node (
91+ id = id ,
9192 dependencies = dependencies ,
9293 max_attempts = sub_details [2 ],
9394 retry_wait_time = sub_details [3 ],
@@ -101,19 +102,21 @@ def deserialize(self, proc_file, restart=False):
101102 )
102103 else :
103104 register .add_node (
105+ id = id ,
104106 dependencies = dependencies ,
105107 max_attempts = sub_details [2 ],
106108 retry_wait_time = sub_details [3 ],
107109 name = sub_details [4 ],
108110 module = 'pyrunner' ,
109111 worker = 'ShellWorker' ,
110112 arguments = [sub_details [5 ]],
111- logfile = sub_details [7 ] if len (sub_details ) > 6 else None ,
113+ logfile = sub_details [6 ] if len (sub_details ) > 6 else None ,
112114 named_deps = False
113115 )
114116 else :
115117 if restart :
116118 register .add_node (
119+ id = id ,
117120 dependencies = dependencies ,
118121 max_attempts = sub_details [2 ],
119122 retry_wait_time = sub_details [3 ],
@@ -127,6 +130,7 @@ def deserialize(self, proc_file, restart=False):
127130 )
128131 else :
129132 register .add_node (
133+ id = id ,
130134 dependencies = dependencies ,
131135 max_attempts = sub_details [2 ],
132136 retry_wait_time = sub_details [3 ],
0 commit comments