python.dqu_subprocess Namespace Reference

Functions
def	_local_apply_core (func, args, q)
def	apply (func, args)

Function Documentation

_local_apply_core()

def python.dqu_subprocess._local_apply_core (   func,   args,   q  )

private

Definition at line 3 of file dqu_subprocess.py.

def _local_apply_core(func, args, q):
    import os
    try:
        q.put(func(*args))
    except Exception as e:
        q.put(e)
        os._exit(1)
 

apply()

def python.dqu_subprocess.apply	(		func,
			args
	)

Definition at line 11 of file dqu_subprocess.py.

def apply(func, args):
    from six.moves.queue import Empty
    from multiprocessing import Process
    from multiprocessing.managers import SyncManager
 
    with SyncManager() as m:
        q = m.Queue()
        p = Process(target=_local_apply_core, args=(func, args, q))
        p.start()
        p.join()
        print('Manager socket is', m.address)
        try:
            rv = q.get(False)
        except Empty:
            raise RuntimeError('daughter died while trying to execute %s%s' % (func.__name__, args))
        if isinstance(rv, BaseException):
            if isinstance(rv, SystemExit):
                print('SystemExit raised by daughter; ignoring')
                return None
            else:
                raise rv
    return rv