Changeset 12581 for main/waeup.kofa/trunk/src/waeup/kofa/async.py

Timestamp:

10 Feb 2015, 14:13:17 (10 years ago)

Author:

uli

Message:

Block jobs if system load is too high.

File:

• main/waeup.kofa/trunk/src/waeup/kofa/async.py (modified) (3 diffs)

main/waeup.kofa/trunk/src/waeup/kofa/async.py

@@ -29 +29 @@
 from zc.async.interfaces import IJob, ObjectAdded
 from ZODB.utils import u64
+from zope.component import getUtility, adapter
 from zope.component.hooks import getSite
 from zope.event import notify
 from waeup.kofa.interfaces import (
-    IJobManager, IProgressable, IJobContainer, WAEUP_KEY,
+    IJobManager, IProgressable, IJobContainer, WAEUP_KEY, IKofaUtils,
     )
+
 
 def compute(num, duration=60):
@@ -144 +146 @@
         """
         site = self._get_site(site)
+        if not getUtility(IKofaUtils).expensive_actions_allowed():
+            return None
         container = self._get_jobs_container(site)
         transaction.begin()
@@ -234 +238 @@
         # This IDatabaseOpenedEvent will be from zope.app.appsetup if that
         # package is around
-        zope.component.adapter(zc.async.interfaces.IDatabaseOpenedEvent)(self)
+        adapter(zc.async.interfaces.IDatabaseOpenedEvent)(self)
         self.db_name = db_name
         return