@@ -232,9 +232,9 @@ def get_next(self, skip=1):
232232 if super (Reader , self )._next (skip ):
233233 entry = super (Reader , self )._get_all ()
234234 if entry :
235- entry ['__REALTIME_TIMESTAMP' ] = self ._get_realtime ()
236- entry ['__MONOTONIC_TIMESTAMP' ] = self ._get_monotonic ()
237- entry ['__CURSOR' ] = self ._get_cursor ()
235+ entry ['__REALTIME_TIMESTAMP' ] = self ._get_realtime ()
236+ entry ['__MONOTONIC_TIMESTAMP' ] = self ._get_monotonic ()
237+ entry ['__CURSOR' ] = self ._get_cursor ()
238238 return self ._convert_entry (entry )
239239 return dict ()
240240
@@ -260,7 +260,7 @@ def query_unique(self, field):
260260 Reader creation.
261261 """
262262 return set (self ._convert_field (field , value )
263- for value in super (Reader , self ).query_unique (field ))
263+ for value in super (Reader , self ).query_unique (field ))
264264
265265 def wait (self , timeout = None ):
266266 """Wait for a change in the journal. `timeout` is the maximum
@@ -335,7 +335,8 @@ def this_boot(self, bootid=None):
335335 def this_machine (self , machineid = None ):
336336 """Add match for _MACHINE_ID equal to the ID of this machine.
337337
338- If specified, machineid should be either a UUID or a 32 digit hex number.
338+ If specified, machineid should be either a UUID or a 32 digit
339+ hex number.
339340
340341 Equivalent to add_match(_MACHINE_ID='machineid').
341342 """
@@ -398,8 +399,8 @@ def send(MESSAGE, MESSAGE_ID=None,
398399 args .append ('MESSAGE_ID=' + id )
399400
400401 if CODE_LINE == CODE_FILE == CODE_FUNC == None :
401- CODE_FILE , CODE_LINE , CODE_FUNC = \
402- _traceback .extract_stack (limit = 2 )[0 ][:3 ]
402+ CODE_FILE , CODE_LINE , CODE_FUNC = \
403+ _traceback .extract_stack (limit = 2 )[0 ][:3 ]
403404 if CODE_FILE is not None :
404405 args .append ('CODE_FILE=' + CODE_FILE )
405406 if CODE_LINE is not None :
0 commit comments