def _apply_function(args):
    """
    Helper function for applying the function in a given source partition
    """
    source, function_obj, kwargs = args
    return source.apply(function_obj, kwargs)
