pull_for_sh_output.py

from sh import zfs_scrub, do_scrub


@hug.cli()
def do_scrub():
    for output in zfs_scrub(''):
        cache.set('key', output.split('%')[0].split(' ')[-1])
    cache.set('key', 'done')


@hug.post()
def start_scrub():
    do_scrub(_bg=True)


@hug.get()
def get_scrub_status():
    return cache.get('key')