def suspend(rq, ctx, duration):
    "Suspends all workers."
    ctx.invoke(
        rq_cli.suspend,
        duration=duration,
        **shared_options(rq)
    )
def suspend ( rq , ctx , duration ) : ctx . invoke ( rq_cli . suspend , duration = duration , ** shared_options ( rq ) )
Suspends all workers.