From 03d917405ea3830ff26eb5ec0bd8349feea389d0 Mon Sep 17 00:00:00 2001 From: Martin Mares <mj@ucw.cz> Date: Mon, 27 Sep 2021 20:00:33 +0200 Subject: [PATCH] =?UTF-8?q?Je=C5=A1t=C4=9B=20jedna=20oprava=20garbage=20co?= =?UTF-8?q?llectoru?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- mo/web/__init__.py | 13 ++++++++----- 1 file changed, 8 insertions(+), 5 deletions(-) diff --git a/mo/web/__init__.py b/mo/web/__init__.py index 7c463ae6..2b29bbff 100644 --- a/mo/web/__init__.py +++ b/mo/web/__init__.py @@ -172,6 +172,12 @@ app.before_request(init_request) ### UWSGI glue ### +def collect_garbage() -> None: + mo.now = mo.util.get_now() + mo.jobs.process_jobs() + mo.users.expire_reg_requests() + + # Čas od času se probudíme a spustíme garbage collector: # - projdeme joby pro případ, že by se ztratil signál # - expirujeme zastaralé joby @@ -179,10 +185,7 @@ app.before_request(init_request) @app.cli.command('gc') def gc(): """Run garbage collector.""" - - mo.now = mo.util.get_now() - mo.jobs.process_jobs() - mo.users.expire_reg_requests() + collect_garbage() try: @@ -193,7 +196,7 @@ try: def mule_timer(signum): # app.logger.debug('Mule: Timer tick') with app.app_context(): - gc() + collect_garbage() # Obykle při vložení jobu dostaneme signál. @signal(42, target='mule') -- GitLab