def apply()

in pythonflow/pfmq/task.py [0:0]

• 5 lines of code
• 2 McCabe index (conditional complexity)

def apply(request, frontend_address, **kwargs):
    """
    Process a request remotely.

    Parameters
    ----------
    request : object
        Request to process.
    frontend_address : str
        Address of the broker frontend.

    Returns
    -------
    ressult : object
        Result of remotely-processed request.
    """
    task = Task([request], frontend_address, start=False, **kwargs)
    task.run()
    for result in task.iter_results(timeout=0):
        return result