def METHOD_NAME():
    """Recieve a result; finish the task in the register and send the result
    back to the scheduler."""
    for key, status, result, err in result_source:
        if key in key_task:
            finish(key)
        yield (key, status, result, err)