Как сделать lock для двух асинхронных программ?

Question

[utsiye]

Требуется лок для двух независимых программ, который будет работать в асинхронном пространстве. Попробовал обернуть filelock в асинхронную обертку - не получилось, блокируется процесс навсегда. Какие есть варианты?

Обертка:

@asynccontextmanager
async def async_file_lock(self):
    loop = asyncio.get_running_loop()
    await loop.run_in_executor(None, self.lock.acquire)
    try:
        yield
    finally:
        await loop.run_in_executor(None, self.lock.release)

Comments

[Vindicar]

Что такое self.lock в коде?

[utsiye]

Vindicar, filelock объект

[shurshur]

utsiye, это именно разные скрипты или это внутри одного скрипта? Если внутри одного, то чем не нравится asyncio.Lock?

upd: И есщё вижу, что есть filelock.AsyncFileLock. Хотя вроде всё равно не то.

Гугл подсказывает aioflock. На первый взгляд похоже на нужное.

[utsiye]

shurshur, пока было внутри 1, то использовал лок от asyncio. Находил aioflock и подобные, но 5 Star и 0 скачиваний смущают. Реализовал на редисе - посмотрю как себя ведет. Спасибо!

[shurshur]

utsiye, там код достаточно простой: делаем неблокирующие flock, между которыми asyncio.sleep. Можно было бы даже самому такое написать.