diff --git a/a_sync/primitives/locks/prio_semaphore.pyx b/a_sync/primitives/locks/prio_semaphore.pyx index 37800888..4c1c59de 100644 --- a/a_sync/primitives/locks/prio_semaphore.pyx +++ b/a_sync/primitives/locks/prio_semaphore.pyx @@ -351,7 +351,7 @@ cdef class _AbstractPrioritySemaphoreContextManager(Semaphore): while self._parent._Semaphore__value <= 0: if self._AbstractPrioritySemaphoreContextManager__waiters is None: self._AbstractPrioritySemaphoreContextManager__waiters = deque() - fut = (self.__loop or self._c_get_loop()).create_future() + fut = self._c_get_loop().create_future() self._AbstractPrioritySemaphoreContextManager__waiters.append(fut) self._parent._potential_lost_waiters.append(fut) try: