diff options
| author | Daniel Schadt <kingdread@gmx.de> | 2023-04-23 11:37:28 +0200 |
|---|---|---|
| committer | Daniel Schadt <kingdread@gmx.de> | 2023-04-23 11:37:28 +0200 |
| commit | 6ed053c4259705e055a70ed18c2336123250b887 (patch) | |
| tree | 641d8bfc0abe8ac15a121c279aa257a99f585341 | |
| parent | d6fb112d693019e1459ede25f2b759bef99d1f24 (diff) | |
| download | fietsboek-6ed053c4259705e055a70ed18c2336123250b887.tar.gz fietsboek-6ed053c4259705e055a70ed18c2336123250b887.tar.bz2 fietsboek-6ed053c4259705e055a70ed18c2336123250b887.zip | |
fietscron: don't run both queues
This has always been intended, but we forgot to set the had_hq_item
flag.
| -rw-r--r-- | fietsboek/scripts/fietscron.py | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/fietsboek/scripts/fietscron.py b/fietsboek/scripts/fietscron.py index d8476a9..b968a18 100644 --- a/fietsboek/scripts/fietscron.py +++ b/fietsboek/scripts/fietscron.py @@ -102,10 +102,11 @@ def run_hittekaart(engine: Engine, data_manager: DataManager, redis: Redis, conf item = redis.spop("hittekaart:queue:high") if item is None: break + had_hq_item = True user = session.execute(select(models.User).filter_by(id=int(item))).scalar() if user is None: LOGGER.debug("User %d had a high-priority queue entry but was not found", item) - break + continue for mode in modes: LOGGER.info("Generating %s for user %d (high-priority)", mode.value, user.id) |