Jobs: Časové parametry jobů jsou nastavitelné

etc/config.py.example

@@ -24,3 +24,9 @@ MAX_CONTENT_LENGTH = 16777216
 
 # Adresář, do kterého ukládáme data (pro vývoj relativní, pro instalaci absolutní)
 DATA_DIR = 'data'
+
+# Jak často se má provádět periodická kontrola dávek [s]
+JOB_GC_PERIOD = 60
+
+# Za jak dlouho expiruje dokončený job [min]
+JOB_EXPIRATION = 5

mo/jobs/__init__.py

@@ -7,6 +7,7 @@ from sqlalchemy import or_
 from typing import Optional, Dict, Callable
 
 import mo
+import mo.config as config
 import mo.db as db
 import mo.util
 from mo.util import logger
@@ -117,7 +118,7 @@ class TheJob:
             return
 
         job.finished_at = mo.util.get_now()
-        job.expires_at = job.finished_at + timedelta(minutes=5)  # FIXME
+        job.expires_at = job.finished_at + timedelta(minutes=config.JOB_EXPIRATION)
         sess.commit()
 
 

mo/web/__init__.py

@@ -96,7 +96,7 @@ try:
 
     # Čas od času se probudíme a projdeme joby pro případ, že by se ztratil signál.
     # Také při tom expirujeme zastaralé joby.
-    @timer(120, target='mule')
+    @timer(config.JOB_GC_PERIOD, target='mule')
     def mule_timer(signum):
         app.logger.debug('Mule: Timer tick')
         with app.app_context():