'Take the set of all local devices for this node from all the EC
policies rings, and distribute them evenly into the number of workers
to be spawned according to the configured worker count. If `devices` is
given in `kwargs` then distribute only those devices.
:param once: False if the worker(s) will be daemonized, True if the
worker(s) will be run once
:param kwargs: optional overrides from the command line'

def get_worker_args(self, once=False, **kwargs):

    if (self.reconstructor_workers < 1):
        return
    override_options = parse_override_options(once=once, **kwargs)
    self.all_local_devices = self.get_local_devices()
    if override_options['override_devices']:
        devices = [d for d in override_options['override_devices'] if (d in self.all_local_devices)]
    else:
        devices = list(self.all_local_devices)
    if (not devices):
        (yield dict(override_options))
        return
    max_devices_per_worker = int(math.ceil(((1.0 * len(self.all_local_devices)) / self.reconstructor_workers)))
    n = int(math.ceil(((1.0 * len(devices)) / max_devices_per_worker)))
    override_devices_per_worker = [devices[i::n] for i in range(n)]
    for override_devices in override_devices_per_worker:
        (yield dict(override_options, override_devices=override_devices))
