summaryrefslogtreecommitdiff
path: root/src/mailman/core/runner.py
diff options
context:
space:
mode:
authorSandesh Kumar Agrawal2013-01-17 05:24:32 +0530
committerSandesh Kumar Agrawal2013-01-17 05:24:32 +0530
commit5ffa4a1323c9e4f75334d2792b8a5f66d4e6f6f0 (patch)
treed489bc8724434a2994d866c4e7f77c883bfe45e5 /src/mailman/core/runner.py
parentc6dd23a544a552995fa4e0e22b8ae5c9dd8544c4 (diff)
downloadmailman-5ffa4a1323c9e4f75334d2792b8a5f66d4e6f6f0.tar.gz
mailman-5ffa4a1323c9e4f75334d2792b8a5f66d4e6f6f0.tar.zst
mailman-5ffa4a1323c9e4f75334d2792b8a5f66d4e6f6f0.zip
Diffstat (limited to 'src/mailman/core/runner.py')
-rw-r--r--src/mailman/core/runner.py11
1 files changed, 9 insertions, 2 deletions
diff --git a/src/mailman/core/runner.py b/src/mailman/core/runner.py
index f088e29bb..05a70ce5b 100644
--- a/src/mailman/core/runner.py
+++ b/src/mailman/core/runner.py
@@ -52,6 +52,7 @@ elog = logging.getLogger('mailman.error')
@implementer(IRunner)
class Runner:
intercept_signals = True
+ is_non_queue_runner = False
def __init__(self, name, slice=None):
"""Create a runner.
@@ -68,8 +69,14 @@ class Runner:
substitutions['name'] = name
self.queue_directory = expand(section.path, substitutions)
numslices = int(section.instances)
- self.switchboard = Switchboard(
- name, self.queue_directory, slice, numslices, True)
+ # Check whether the runner is queue runner or not; non queue runner should not have queue_directory or switchboard instance.
+ if self.is_non_queue_runner:
+ self.queue_directory = None
+ self.switchboard= None
+ else:
+ self.queue_directory = expand(section.path, substitutions)
+ self.switchboard = Switchboard(
+ name, self.queue_directory, slice, numslices, True)
self.sleep_time = as_timedelta(section.sleep_time)
# sleep_time is a timedelta; turn it into a float for time.sleep().
self.sleep_float = (86400 * self.sleep_time.days +