diff options
| author | Sandesh Kumar Agrawal | 2013-01-17 05:24:32 +0530 |
|---|---|---|
| committer | Sandesh Kumar Agrawal | 2013-01-17 05:24:32 +0530 |
| commit | 5ffa4a1323c9e4f75334d2792b8a5f66d4e6f6f0 (patch) | |
| tree | d489bc8724434a2994d866c4e7f77c883bfe45e5 /src/mailman/core/runner.py | |
| parent | c6dd23a544a552995fa4e0e22b8ae5c9dd8544c4 (diff) | |
| download | mailman-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.py | 11 |
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 + |
