lint

Signed-off-by: Jason Ray <[email protected]>
jasonray · Dec 25, 2023 · b8ff7ce · b8ff7ce
1 parent 03de170
commit b8ff7ce
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/pulpo_messaging/file_queue_adapter.py b/pulpo_messaging/file_queue_adapter.py
@@ -156,10 +156,11 @@ def peek(self, message_id: str) -> Message:
         status = self.lookup_message_state(message_id=message_id)
         logger.debug(f'peek {message_id=} {status=}')
         # unknown, queue, lock, complete.success, complete.fail
-        if status== 'queue':
+        if status == 'queue':
             return self._load_message_from_file(self._get_message_file_path(message_id))
-        elif status== 'lock':
+        if status == 'lock':
             return self._load_message_from_file(self._get_lock_file_path(message_id))
+        return None
 
     def delete(self, message_id: str):
         status = self.lookup_message_state(message_id=message_id)