(client, command_args)
| 143 | |
| 144 | |
| 145 | async def async_set_fail_point(client, command_args): |
| 146 | cmd = SON([("configureFailPoint", "failCommand")]) |
| 147 | cmd.update(command_args) |
| 148 | await client.admin.command(cmd) |
| 149 | |
| 150 | |
| 151 | async def async_joinall(tasks): |