def any(objects, timeout_ms=WAIT.INFINITE):
    handles = [o.pyobject() for o in objects]
    result = wrapped(win32event.WaitForMultipleObjects, handles, 0, timeout_ms)
    if result == WAIT.TIMEOUT:
        raise x_ipc_timeout(None, "any", "Wait timed out")
    else:
        return objects[result - WAIT.OBJECT_0]
Register a new task implementation with the execution system
dataset/ETHPy150Open tjguk/winsys/winsys/ipc.py/any--crossover with--dataset/ETHPy150Open cloudera/ibis/ibis/tasks.py/register_task