(step)
| 319 | |
| 320 | |
| 321 | def _get_step_context(step): |
| 322 | proto = step.Proto() |
| 323 | if proto.should_stop_blob: |
| 324 | return call('loop'), False |
| 325 | if proto.num_iter and proto.num_iter != 1: |
| 326 | return call('loop', [proto.num_iter]), False |
| 327 | if proto.num_concurrent_instances > 1: |
| 328 | return ( |
| 329 | call('parallel', |
| 330 | [('num_instances', proto.num_concurrent_instances)]), |
| 331 | len(step.Substeps()) > 1) |
| 332 | concurrent = proto.concurrent_substeps and len(step.Substeps()) > 1 |
| 333 | if concurrent: |
| 334 | return call('parallel'), True |
| 335 | if proto.report_net: |
| 336 | return call('run_once'), False |
| 337 | return None, False |
| 338 | |
| 339 | |
| 340 | @Printer.register(ExecutionStep) |
no test coverage detected
searching dependent graphs…