-
Notifications
You must be signed in to change notification settings - Fork 9
Ability to list and cancel running (and queued) actions of bubuku #64
Conversation
_print_table(table) | ||
|
||
|
||
@actions.command('delete', help='List all the actions on broker(s)') |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
help is incorrect
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
@click.option('--action', type=click.STRING, | ||
help='Action to delete') | ||
@click.option('--broker', type=click.STRING, | ||
help='Broker id to list actions on. By default all brokers are enumerated') |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
help is incorrect
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
fixed ff19b75
@@ -100,6 +102,91 @@ def swap_partitions(threshold: int): | |||
RemoteCommandExecutorCheck.register_fatboy_slim(zookeeper, threshold_kb=threshold) | |||
|
|||
|
|||
@cli.group(name='actions', help='Work with running actions') |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
What's this?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
@v-stepanov I don't fully get the question. It's group description if you run bubuku-cli actions
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
What does group description do?
finish = cur_time + (0.1 if timeout <= 0 else timeout) | ||
while cur_time < finish: | ||
try: | ||
commnad = __COMMAND_QUEUE.get(block=True, timeout=finish - cur_time) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
commnad
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
@v-stepanov fixed ff19b75
Closes #61 #62