diff options
| author | Abhilash Raj | 2014-09-13 22:48:48 +0530 |
|---|---|---|
| committer | Abhilash Raj | 2014-09-13 22:48:48 +0530 |
| commit | f8212e1d9d32f29039b620d8805f1a53f579dd34 (patch) | |
| tree | e76202f651694fa333d9acf2d8531094851c81c0 /src/mailman/model/messagestore.py | |
| parent | a9b38e7643ac7dd8d526af22a6e3e9ea73933f59 (diff) | |
| download | mailman-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.py | 8 |
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) |
