Commands and Tethers

This is implemented through the Command and Tether (actually MultiCommand).

Callback Invocation

For a regular command, the callback is executed whenever the command runs. If the script is the only command, it will always fire (unless a parameter callback prevents it. This for instance happens if someone passes --help to the script).

For tethers and multi commands, the situation looks different. In this case, the callback fires whenever a subcommand fires (unless this behavior is changed). What this means in practice is that an outer command runs when an inner command runs:

from quo import echo
from quo.console import app, tether

@tether()
@app('@debug/@no-debug', default=False)
def cli(debug):
    echo(f"Debug mode is {'on' if debug else 'off'}")

@cli.command()
def sync():
    echo('Syncing')

Passing Parameters

quo strictly separates parameters between commands and subcommands. What this means is that apps and args for a specific command have to be specified after the command name itself, but before any other command names.

This behavior is already observable with the predefined --help option. Suppose we have a program called tool.py, containing a subcommand called sub.

  • tool.py --help will return the help for the whole program (listing subcommands).

  • tool.py sub --help will return the help for the sub subcommand.

  • But tool.py --help sub will treat --help as an arg for the main program. quo then invokes the callback for --help, which prints the help and aborts the program before quo can process the subcommand.

Nested Handling and Climes

As you can see from the earlier example, the basic command group accepts a debug arg which is passed to its callback, but not to the sync command itself. The sync command only accepts its own args.

This allows tools to act completely independent of each other, but how does one command talk to a nested one? The answer to this is the Clime.

Each time a command is invoked, a new context is created and linked with the parent context. Normally, you can’t see these contexts, but they are there. Contexts are passed to parameter callbacks together with the value automatically. Commands can also ask for the context to be passed by marking themselves with the pass_context() decorator. In that case, the context is passed as first argument.

The context can also carry a program specified object that can be used for the program’s purposes. What this means is that you can build a script like this:

from quo import pass_context
from quo.console import app, tether

@tether()
@app('--debug/--no-debug', default=False)
@pass_context
def cli(clime, debug):
    # ensure that ctx.obj exists and is a dict (in case `cli()` is called
    # by means other than the `if` block below)
    clime.ensure_object(dict)

    clime.obj['DEBUG'] = debug

@cli.command()
@pass_context
def sync(clime):
    echo(f"Debug is {'on' if clime.obj['DEBUG'] else 'off'}")

if __name__ == '__main__':
    cli(obj={})

If the object is provided, each context will pass the object onwards to its children, but at any level a context’s object can be overridden. To reach to a parent, context.parent can be used.

In addition to that, instead of passing an object down, nothing stops the application from modifying global state. For instance, you could just flip a global DEBUG variable and be done with it.

Decorating Commands

As you have seen in the earlier example, a decorator can change how a command is invoked. What actually happens behind the scenes is that callbacks are always invoked through the Clime.invoke() method which automatically invokes a command correctly (by either passing the context or not).

This is very useful when you want to write custom decorators. For instance, a common pattern would be to configure an object representing state and then storing it on the context and then to use a custom decorator to find the most recent object of this sort and pass it as first argument.

For instance, the pass_obj() decorator can be implemented like this:

from functools import update_wrapper
from quo import pass_context

def pass_obj(f):
    @pass_context
    def new_func(clime, **args, **kwargs):
        return clime.invoke(f, clime.obj, *args, **kwargs)
    return update_wrapper(new_func, f)

The Clime.invoke() command will automatically invoke the function in the correct way, so the function will either be called with f(clime, obj) or f(obj) depending on whether or not it itself is decorated with pass_context().

This is a very powerful concept that can be used to build very complex nested applications; see complex-guide for more information.

Tether Invocation Without Command

By default, a tether or multi command is not invoked unless a subcommand is passed. In fact, not providing a command automatically passes --help by default. This behavior can be changed by passing invoke_without_command=True to a group. In that case, the callback is always invoked instead of showing the help page. The context object also includes information about whether or not the invocation would go to a subcommand.

Example:

from quo import echo, pass_context
from quo.console import tether

@tether(invoke_without_command=True)
@quo.pass_context
def cli(clime):
    if clime.invoked_subcommand is None:
        echo('I was invoked without subcommand')
    else:
        echo(f"I am about to invoke {clime.invoked_subcommand}")

@cli.command()
def sync():
    echo('The subcommand')

Merging Multi Commands

In addition to implementing custom multi commands, it can also be interesting to merge multiple together into one script. While this is generally not as recommended as it nests one below the other, the merging approach can be useful in some circumstances for a nicer shell experience.

The default implementation for such a merging system is the CommandCollection class. It accepts a list of other multi commands and makes the commands available on the same level.

Example usage:

from quo import CommandCollection
from quo.console import tether, command

@tether()
def cli1():
    pass

@cli1.command()
def cmd1():
    """Command on cli1"""

@tether()
def cli2():
    pass

@cli2.command()
def cmd2():
    """Command on cli2"""

cli = CommandCollection(sources=[cli1, cli2])

if __name__ == '__main__':
    cli()

In case a command exists in more than one source, the first source wins.

Multi Command Chaining

Sometimes it is useful to be allowed to invoke more than one subcommand in one go. For instance if you have installed a setuptools package before you might be familiar with the setup.py sdist bdist_wheel command chain which invokes sdist before bdist_wheel. This is very simple to implement. All you have to do is to pass chain=True to your multicommand:

from quo import echo
from quo.console import command, tether

@tether(chain=True)
def cli():
    pass


@cli.command('sdist')
def sdist():
    echo('sdist called')


@cli.command('bdist_wheel')
def bdist_wheel():
    echo('bdist_wheel called')

When using multi command chaining you can only have one command (the last) use nargs=-1 on an argument. It is also not possible to nest multi commands below chained multicommands. Other than that there are no restrictions on how they work. They can accept apps and args as normal. The order between apps and args is limited for chained commands. Currently only --apps args order is allowed.

Another note: the Clime.invoked_subcommand attribute is a bit useless for multi commands as it will give '*' as value if more than one command is invoked. This is necessary because the handling of subcommands happens one after another so the exact subcommands that will be handled are not yet available when the callback fires.

Note

It is currently not possible for chain commands to be nested. This will be fixed in future versions of quo.

Multi Command Pipelines

A very common usecase of multi command chaining is to have one command process the result of the previous command. There are various ways in which this can be facilitated. The most obvious way is to store a value on the context object and process it from function to function. This works by decorating a function with pass_context() after which the context object is provided and a subcommand can store its data there.

Another way to accomplish this is to setup pipelines by returning processing functions. Think of it like this: when a subcommand gets invoked it processes all of its parameters and comes up with a plan of how to do its processing. At that point it then returns a processing function and returns.

Where do the returned functions go? The chained multicommand can register a callback with MultiCommand.resultcallback() that goes over all these functions and then invoke them.

To make this a bit more concrete consider this example:

from quo import echo
from quo.console import app, tether
from quo.types import File

@tether(chain=True, invoke_without_command=True)
@app('-i', '--input', type=File('r'))
def cli(input):
    pass

@cli.resultcallback()
def process_pipeline(processors, input):
    iterator = (x.rstrip('\r\n') for x in input)
    for processor in processors:
        iterator = processor(iterator)
    for item in iterator:
        echo(item)

@cli.command('uppercase')
def make_uppercase():
    def processor(iterator):
        for line in iterator:
            yield line.upper()
    return processor

@cli.command('lowercase')
def make_lowercase():
    def processor(iterator):
        for line in iterator:
            yield line.lower()
    return processor

@cli.command('strip')
def make_strip():
    def processor(iterator):
        for line in iterator:
            yield line.strip()
    return processor

That’s a lot in one go, so let’s go through it step by step.

  1. The first thing is to make a quo.console.tether() that is chainable. In addition to that we also instruct quo to invoke even if no subcommand is defined. If this would not be done, then invoking an empty pipeline would produce the help page instead of running the result callbacks.

  2. The next thing we do is to register a result callback on our tether This callback will be invoked with an arg which is the list of all return values of all subcommands and then the same keyword parameters as our group itself. This means we can access the input file easily there without having to use the context object.

  3. In this result callback we create an iterator of all the lines in the input file and then pass this iterator through all the returned callbacks from all subcommands and finally we print all lines to stdout.

After that point we can register as many subcommands as we want and each subcommand can return a processor function to modify the stream of lines.

One important thing of note is that quo shuts down the context after each callback has been run. This means that for instance file types cannot be accessed in the processor functions as the files will already be closed there. This limitation is unlikely to change because it would make resource handling much more complicated. For such it’s recommended to not use the file type and manually open the file through openfile().

For a more complex example that also improves upon handling of the pipelines have a look at the imagepipe multi command chaining demo in the quo repository. It implements a pipeline based image editing tool that has a nice internal structure for the pipelines.

Overriding Defaults

By default, the default value for a parameter is pulled from the default flag that is provided when it’s defined, but that’s not the only place defaults can be loaded from. The other place is the Clime.default_map (a dictionary) on the context. This allows defaults to be loaded from a configuration file to override the regular defaults.

This is useful if you plug in some commands from another package but you’re not satisfied with the defaults.

The default map can be nested arbitrarily for each subcommand:

default_map = {
    "debug": True,  # default for a top level option
    "runserver": {"port": 5000}  # default for a subcommand
}

The default map can be provided when the script is invoked, or overridden at any point by commands. For instance, a top-level command could load the defaults from a configuration file.

Example usage:

from quo import print
from quo.console import app, tether

@tether()
def cli():
    pass

@cli.command()
@app('--port', default=8000)
def runserver(port):
    print(f"Serving on http://127.0.0.1:{port}/")

if __name__ == '__main__':
    cli(default_map={
        'runserver': {
            'port': 5000
        }
    })

Clime Defaults

You can override defaults for contexts not just when calling your script, but also in the decorator that declares a command. For instance given the previous example which defines a custom default_map this can also be accomplished in the decorator now.

This example does the same as the previous example:

from quo import print
from quo.console import app, tether

CONTEXT_SETTINGS = dict(
    default_map={'runserver': {'port': 5000}}
)

@tether(context_settings=CONTEXT_SETTINGS)
def cli():
    pass

@cli.command()
@app('@port', default=8000)
def runserver(port):
    print(f"Serving on http://127.0.0.1:{port}/")

if __name__ == '__main__':
    cli()

Command Return Values

Quo supports return values from command callbacks. This enables a whole range of features that were previously hard to implement.

In essence any command callback can now return a value. This return value is bubbled to certain receivers. One usecase for this has already been show in the example of Multi Command Chaining where it has been demonstrated that chained multi commands can have callbacks that process all return values.

When working with command return values in quo, this is what you need to know:

  • The return value of a command callback is generally returned from the BaseCommand.invoke() method. The exception to this rule has to do with Tethers:

    • In a tether, the return value is generally the return value of the subcommand invoked. The only exception to this rule is that the return value is the return value of the group callback if it’s invoked without arguments and invoke_without_command is enabled.

    • If a group is set up for chaining then the return value is a list of all subcommands’ results.

    • Return values of groups can be processed through a MultiCommand.result_callback. This is invoked with the list of all return values in chain mode, or the single return value in case of non chained commands.

  • The return value is bubbled through from the Clime.invoke() and Clime.forward() methods. This is useful in situations where you internally want to call into another command.

  • quo does not have any hard requirements for the return values and does not use them itself. This allows return values to be used for custom decorators or workflows (like in the multi command chaining example).

  • When a quo script is invoked as command line application (through BaseCommand.main()) the return value is ignored unless the standalone_mode is disabled in which case it’s bubbled through.