parsl/executors/high_throughput/interchange.py
def starter(comm_q, *args, **kwargs):
    """Start the interchange process

    The executor is expected to call this function. The args, kwargs match that of the Interchange.__init__
    """
    # logger = multiprocessing.get_logger()
    ic = Interchange(*args, **kwargs)
    comm_q.put((ic.worker_task_port,
                ic.worker_result_port))
    ic.start()
def starter(comm_q, *args, **kwargs):
    """Start the interchange process

    The executor is expected to call this function. The args, kwargs match that of the Interchange.__init__
    """
    # logger = multiprocessing.get_logger()
    ic = Interchange(*args, **kwargs)
    comm_q.put((ic.worker_task_port,
                ic.worker_result_port))
    ic.start()
def starter ( comm_q , * args , * * kwargs ) : # logger = multiprocessing.get_logger() ic = Interchange ( * args , * * kwargs ) comm_q . put ( ( ic . worker_task_port , ic . worker_result_port ) ) ic . start ( )
Start the interchange process

    The executor is expected to call this function. The args, kwargs match that of the Interchange.__init__
Start the interchange process