Add a "report step" to this TaskGroup. This step will run repeatedly every `interval_ms` milliseconds for the duration of the TaskGroup execution on each of the nodes. It is guaranteed that this step will be run at least once after every Task in the node has finished
(self, step=None, node=None, interval_ms=1000)
| 239 | return used |
| 240 | |
| 241 | def report_step(self, step=None, node=None, interval_ms=1000): |
| 242 | """ |
| 243 | Add a "report step" to this TaskGroup. This step will run repeatedly |
| 244 | every `interval_ms` milliseconds for the duration of the TaskGroup |
| 245 | execution on each of the nodes. It is guaranteed that this step |
| 246 | will be run at least once after every Task in the node has finished. |
| 247 | """ |
| 248 | step = core.to_execution_step(step) |
| 249 | step.RunEveryMillis(interval_ms) |
| 250 | self._report_steps.append((str(node or Node.current(node)), step)) |
| 251 | |
| 252 | def report_net(self, net=None, node=None, report_interval=5): |
| 253 | """ |
no test coverage detected