def _embedding_aggregator(output_queue, n_worker):
    """ Process that aggregates the results of the workers.
        This should be the main/original process.

    Parameters
    ----------
    output_queue: Queue
        This queue is the output queue of the workers.
    n_worker: int
        The number of worker processes.

    Returns
    -------
    Aggregated embedding dictionary.
    """
    embedding = {}
    num_done = 0
    while num_done < n_worker:
        new_embedding = output_queue.get()
        if new_embedding == 'DONE':
            num_done += 1
        else:
            embedding.update(new_embedding)
    return embedding
