Inspect commands now accept arguments.

Fixes #6705.
celery · Apr 26, 2021 · 230c9ac · 230c9ac
1 parent 850c62a
commit 230c9ac
Showing 1 changed file with 7 additions and 3 deletions.
diff --git a/celery/bin/control.py b/celery/bin/control.py
@@ -95,7 +95,8 @@ def status(ctx, timeout, destination, json, **kwargs):
             nodecount, text.pluralize(nodecount, 'node')))
 
 
-@click.command(cls=CeleryCommand)
+@click.command(cls=CeleryCommand,
+               context_settings={'allow_extra_args': True})
 @click.argument("action", type=click.Choice([
     name for name, info in Panel.meta.items()
     if info.type == 'inspect' and info.visible
@@ -128,9 +129,12 @@ def inspect(ctx, action, timeout, destination, json, **kwargs):
     """
     callback = None if json else partial(_say_remote_command_reply, ctx,
                                          show_reply=True)
-    replies = ctx.obj.app.control.inspect(timeout=timeout,
+    arguments = _compile_arguments(action, ctx.args)
+    inspect = ctx.obj.app.control.inspect(timeout=timeout,
                                           destination=destination,
-                                          callback=callback)._request(action)
+                                          callback=callback)
+    replies = inspect._request(action,
+                               **arguments)
 
     if not replies:
         raise CeleryCommandException(