summaryrefslogtreecommitdiff
path: root/src/mailman/runners/digest.py
diff options
context:
space:
mode:
authorBarry Warsaw2015-09-06 23:52:57 -0400
committerBarry Warsaw2015-09-06 23:52:57 -0400
commitc8b2d7078c0f941b20a7b235693d4ffe8768209b (patch)
treeb7a83421fd23e2b3819b77be6b1388a2af23fb10 /src/mailman/runners/digest.py
parentc5b8e9bfc0757b51a5ee5d866d247cbb9139c244 (diff)
downloadmailman-c8b2d7078c0f941b20a7b235693d4ffe8768209b.tar.gz
mailman-c8b2d7078c0f941b20a7b235693d4ffe8768209b.tar.zst
mailman-c8b2d7078c0f941b20a7b235693d4ffe8768209b.zip
Diffstat (limited to 'src/mailman/runners/digest.py')
-rw-r--r--src/mailman/runners/digest.py26
1 files changed, 16 insertions, 10 deletions
diff --git a/src/mailman/runners/digest.py b/src/mailman/runners/digest.py
index ad6e0b1c5..388f7ffc2 100644
--- a/src/mailman/runners/digest.py
+++ b/src/mailman/runners/digest.py
@@ -358,7 +358,9 @@ class DigestRunner(Runner):
email_address = member.address.original_email
if member.delivery_mode == DeliveryMode.plaintext_digests:
rfc1153_recipients.add(email_address)
- elif member.delivery_mode == DeliveryMode.mime_digests:
+ # We currently treat summary_digests the same as mime_digests.
+ elif member.delivery_mode in (DeliveryMode.mime_digests,
+ DeliveryMode.summary_digests):
mime_recipients.add(email_address)
else:
raise AssertionError(
@@ -368,7 +370,9 @@ class DigestRunner(Runner):
for address, delivery_mode in mlist.last_digest_recipients:
if delivery_mode == DeliveryMode.plaintext_digests:
rfc1153_recipients.add(address.original_email)
- elif delivery_mode == DeliveryMode.mime_digests:
+ # We currently treat summary_digests the same as mime_digests.
+ elif delivery_mode in (DeliveryMode.mime_digests,
+ DeliveryMode.summary_digests):
mime_recipients.add(address.original_email)
else:
raise AssertionError(
@@ -376,11 +380,13 @@ class DigestRunner(Runner):
address, delivery_mode))
# Send the digests to the virgin queue for final delivery.
queue = config.switchboards['virgin']
- queue.enqueue(mime,
- recipients=mime_recipients,
- listid=mlist.list_id,
- isdigest=True)
- queue.enqueue(rfc1153,
- recipients=rfc1153_recipients,
- listid=mlist.list_id,
- isdigest=True)
+ if len(mime_recipients) > 0:
+ queue.enqueue(mime,
+ recipients=mime_recipients,
+ listid=mlist.list_id,
+ isdigest=True)
+ if len(rfc1153_recipients) > 0:
+ queue.enqueue(rfc1153,
+ recipients=rfc1153_recipients,
+ listid=mlist.list_id,
+ isdigest=True)