diff --git a/daliuge-engine/dlg/manager/session.py b/daliuge-engine/dlg/manager/session.py
index 8514b1f69..a5730b0b0 100644
--- a/daliuge-engine/dlg/manager/session.py
+++ b/daliuge-engine/dlg/manager/session.py
@@ -103,12 +103,10 @@ def __init__(self, sessionId):
                 self.sessionId = sessionId
 
             def filter(self, record):
-                if hasattr(record, 'session_id'):
-                    return record.session_id == self.sessionId
-                return False
+                return getattr(record, 'session_id', None) == self.sessionId
 
         fmt = '%(asctime)-15s [%(levelname)5.5s] [%(threadName)15.15s] '
-        fmt += '[%(session_id)10.10s] [%(drop_uid)10.10s] '
+        fmt += '[%(drop_uid)10.10s] '
         fmt += '%(name)s#%(funcName)s:%(lineno)s %(message)s'
         fmt = logging.Formatter(fmt)
         fmt.converter = time.gmtime