Kill running flows.
(self, flows: Sequence[flow.Flow])
| 91 | |
| 92 | @command.command("flow.kill") |
| 93 | def kill(self, flows: Sequence[flow.Flow]) -> None: |
| 94 | """ |
| 95 | Kill running flows. |
| 96 | """ |
| 97 | updated = [] |
| 98 | for f in flows: |
| 99 | if f.killable: |
| 100 | f.kill() |
| 101 | updated.append(f) |
| 102 | logger.log(ALERT, "Killed %s flows." % len(updated)) |
| 103 | ctx.master.addons.trigger(hooks.UpdateHook(updated)) |
| 104 | |
| 105 | # FIXME: this will become view.revert later |
| 106 | @command.command("flow.revert") |