fixed timeout of process map updates lock

This commit is contained in:
Jenny Danzmayr 2024-09-08 19:48:53 +02:00
parent 44c4264f7d
commit 42da0ffa27

View file

@ -151,9 +151,9 @@ class MapUpdate(models.Model):
import redis import redis
lock_aquired = None lock_aquired = None
client = redis.Redis(connection_pool=settings.REDIS_CONNECTION_POOL) client = redis.Redis(connection_pool=settings.REDIS_CONNECTION_POOL)
lock = client.lock('mapupdate:process_updates:lock') lock = client.lock('mapupdate:process_updates:lock', timeout=1800)
try: try:
lock_aquired = lock.acquire(blocking=False, blocking_timeout=1800) lock_aquired = lock.acquire(blocking=False)
if not lock_aquired: if not lock_aquired:
raise cls.ProcessUpdatesAlreadyRunning raise cls.ProcessUpdatesAlreadyRunning
cache.set('mapdata:last_process_updates_start', int(time.time()), None) cache.set('mapdata:last_process_updates_start', int(time.time()), None)