policyd: close redis connection after counters reset.

2026-10-17 05:41:25 +02:00 · 2020-07-15 09:20:09 +02:00
parent 0d47e08e81
commit 4f6de1519a
1 changed files with 2 additions and 0 deletions
@@ -209,6 +209,8 @@ async def reset_counters():
    for mb in mboxes:
        rclient.hset(
            constants.REDIS_HASHNAME, mb.full_address, mb.message_limit)
+    rclient.close()
+    await rclient.wait_closed()
    # reschedule
    asyncio.ensure_future(run_at(get_next_execution_dt(), reset_counters))