summaryrefslogtreecommitdiff
path: root/src/mailman/model/messagestore.py
diff options
context:
space:
mode:
authorAbhilash Raj2014-09-13 22:48:48 +0530
committerAbhilash Raj2014-09-13 22:48:48 +0530
commitf8212e1d9d32f29039b620d8805f1a53f579dd34 (patch)
treee76202f651694fa333d9acf2d8531094851c81c0 /src/mailman/model/messagestore.py
parenta9b38e7643ac7dd8d526af22a6e3e9ea73933f59 (diff)
downloadmailman-f8212e1d9d32f29039b620d8805f1a53f579dd34.tar.gz
mailman-f8212e1d9d32f29039b620d8805f1a53f579dd34.tar.zst
mailman-f8212e1d9d32f29039b620d8805f1a53f579dd34.zip
Diffstat (limited to 'src/mailman/model/messagestore.py')
-rw-r--r--src/mailman/model/messagestore.py8
1 files changed, 4 insertions, 4 deletions
diff --git a/src/mailman/model/messagestore.py b/src/mailman/model/messagestore.py
index 69860a6a1..f9f224dd6 100644
--- a/src/mailman/model/messagestore.py
+++ b/src/mailman/model/messagestore.py
@@ -59,7 +59,7 @@ class MessageStore:
# Calculate and insert the X-Message-ID-Hash.
message_id = message_ids[0]
# Complain if the Message-ID already exists in the storage.
- existing = store.find(Message, Message.message_id == message_id).one()
+ existing = store.query(Message).filter(Message.message_id == message_id).first()
if existing is not None:
raise ValueError(
'Message ID already exists in message store: {0}'.format(
@@ -107,7 +107,7 @@ class MessageStore:
@dbconnection
def get_message_by_id(self, store, message_id):
- row = store.find(Message, message_id=message_id).one()
+ row = store.query(Message).filter_by(message_id=message_id).first()
if row is None:
return None
return self._get_message(row)
@@ -120,7 +120,7 @@ class MessageStore:
# US-ASCII.
if isinstance(message_id_hash, unicode):
message_id_hash = message_id_hash.encode('ascii')
- row = store.find(Message, message_id_hash=message_id_hash).one()
+ row = store.query(Message).filter_by(message_id_hash=message_id_hash).first()
if row is None:
return None
return self._get_message(row)
@@ -133,7 +133,7 @@ class MessageStore:
@dbconnection
def delete_message(self, store, message_id):
- row = store.query(Message).filter_by(message_id=message_id).one()
+ row = store.query(Message).filter_by(message_id=message_id).first()
if row is None:
raise LookupError(message_id)
path = os.path.join(config.MESSAGES_DIR, row.path)