@ioflo.base.deeding.deedify('SaltRaetWorkerFork', ioinits={'opts': '.salt.opts', 'proc_mgr': '.salt.usr.proc_mgr', 'worker_verify': '.salt.var.worker_verify', 'access_keys': '.salt.access_keys', 'mkey': '.salt.var.zmq.master_key', 'aes': '.salt.var.zmq.aes'})
def worker_fork(self):
 for index in range(int(self.opts.value['worker_threads'])):
  time.sleep(0.01)
  self.proc_mgr.value.add_process(Worker, args=(self.opts.value, (index + 1), self.worker_verify.value, self.access_keys.value, self.mkey.value, self.aes.value))

@ ioflo . base . deeding . deedify ( 'SaltRaetWorkerFork' , ioinits = { 'opts' : '.salt.opts' , 'proc_mgr' : '.salt.usr.proc_mgr' , 'worker_verify' : '.salt.var.worker_verify' , 'access_keys' : '.salt.access_keys' , 'mkey' : '.salt.var.zmq.master_key' , 'aes' : '.salt.var.zmq.aes' } ) def worker_fork ( self ) : for index in range ( int ( self . opts . value [ 'worker_threads' ] ) ) : time . sleep ( 0.01 ) self . proc_mgr . value . add_process ( Worker , args = ( self . opts . value , ( index + 1 ) , self . worker_verify . value , self . access_keys . value , self . mkey . value , self . aes . value ) )
fork off the worker procs floscript: do salt raet worker fork at enter .