(ctx)
| 26 | |
| 27 | |
| 28 | def process_args(ctx): |
| 29 | # reset device by args |
| 30 | # argdev = ctx.args.gpus or ctx.args.xpus or ctx.args.npus |
| 31 | argdev = ctx.args.devices |
| 32 | if argdev: |
| 33 | for d in argdev.split(','): |
| 34 | if d not in ctx.node.device.labels: |
| 35 | ctx.logger.error( |
| 36 | f'Device not found {d} from {argdev} for setting {ctx.node.device.labels}' |
| 37 | ) |
| 38 | |
| 39 | if ctx.args.ips: |
| 40 | ips = ctx.args.ips.split(',') |
| 41 | if '127.0.0.1' in ips and len(ips) != 1: |
| 42 | raise ValueError("127.0.0.1 in ips is not allowed in multi-nodes.") |
| 43 | |
| 44 | |
| 45 | def collective_compatible(ctx): |
nothing calls this directly
no test coverage detected