(An Untitled Masterwork)

ActivePublic

Actions

import os
import sys

import cumin
from cumin import backends, query, transport, transports

config = cumin.Config()
hosts = query.Query(config).execute('*')

with open(os.devnull, 'w') as discard_output:
    oldstdout = sys.stdout
    oldstderr = sys.stderr
    sys.stdout = discard_output
    sys.stderr = discard_output

    worker = transport.Transport.new(config)
    worker.target = transports.Target(hosts)
    worker.commands = [transports.Command('date')]
    worker.handler = 'sync'
    exit_code = worker.execute()

    sys.stdout = oldstdout
    sys.stderr = oldstderr