code reformat with automatic function

Author: Alin G. Chitu

src/pyxdf/pyxdf.py

@@ -73,21 +73,21 @@ def __init__(self, xml):
 
 
 def load_xdf(
-    filename,
-    select_streams=None,
-    *,
-    on_chunk=None,
-    synchronize_clocks=True,
-    handle_clock_resets=True,
-    dejitter_timestamps=True,
-    jitter_break_threshold_seconds=1,
-    jitter_break_threshold_samples=500,
-    clock_reset_threshold_seconds=5,
-    clock_reset_threshold_stds=5,
-    clock_reset_threshold_offset_seconds=1,
-    clock_reset_threshold_offset_stds=10,
-    winsor_threshold=0.0001,
-    verbose=None,
+        filename,
+        select_streams=None,
+        *,
+        on_chunk=None,
+        synchronize_clocks=True,
+        handle_clock_resets=True,
+        dejitter_timestamps=True,
+        jitter_break_threshold_seconds=1,
+        jitter_break_threshold_samples=500,
+        clock_reset_threshold_seconds=5,
+        clock_reset_threshold_stds=5,
+        clock_reset_threshold_offset_seconds=1,
+        clock_reset_threshold_offset_stds=10,
+        winsor_threshold=0.0001,
+        verbose=None,
 ):
     """Import an XDF file.
 
@@ -513,7 +513,7 @@ def _xml2dict(t):
 
 def _scan_forward(f):
     """Scan forward through file object until after the next boundary chunk."""
-    blocklen = 2**20
+    blocklen = 2 ** 20
     signature = bytes(
         [
             0x43,
@@ -587,10 +587,10 @@ def _segment_clock_diff(diff, thresh_stds, thresh_secs):
 
 
 def _detect_corrupted_clock_offset(
-    clock_times,
-    clock_values,
-    time_thresh=10.0,
-    value_thresh=10.0,
+        clock_times,
+        clock_values,
+        time_thresh=10.0,
+        value_thresh=10.0,
 ):
     """Detect if the last clock offset entry is statistically anomalous.
 
@@ -736,11 +736,11 @@ def _truncate_corrupted_offsets(temp, streams):
 
 
 def _detect_clock_resets(
-    stream,
-    time_thresh_stds,
-    time_thresh_secs,
-    value_thresh_stds,
-    value_thresh_secs,
+        stream,
+        time_thresh_stds,
+        time_thresh_secs,
+        value_thresh_stds,
+        value_thresh_secs,
 ):
     # First detect potential breaks in the synchronization data; this is
     # only necessary when the importer should be able to deal with
@@ -778,13 +778,13 @@ def _detect_clock_resets(
 
 
 def _clock_sync(
-    streams,
-    handle_clock_resets=True,
-    reset_threshold_stds=5,
-    reset_threshold_seconds=5,
-    reset_threshold_offset_stds=10,
-    reset_threshold_offset_seconds=1,
-    winsor_threshold=0.0001,
+        streams,
+        handle_clock_resets=True,
+        reset_threshold_stds=5,
+        reset_threshold_seconds=5,
+        reset_threshold_offset_stds=10,
+        reset_threshold_offset_seconds=1,
+        winsor_threshold=0.0001,
 ):
     for stream_id, stream in streams.items():
         if len(stream.time_stamps) > 0:
@@ -882,7 +882,7 @@ def _clock_sync(
                         ts_slice = slice(ts_start, ts_stop)
                         ts_start = ts_stop
                         stream.time_stamps[ts_slice] += (
-                            coef_i[0] + coef_i[1] * stream.time_stamps[ts_slice]
+                                coef_i[0] + coef_i[1] * stream.time_stamps[ts_slice]
                         )
     return streams
 
@@ -913,9 +913,9 @@ def _stream_can_drop_samples(stream_meta):
 
     synchronization = desc[0].get("synchronization")
     if (
-        not isinstance(synchronization, list)
-        or len(synchronization) == 0
-        or not isinstance(synchronization[0], dict)
+            not isinstance(synchronization, list)
+            or len(synchronization) == 0
+            or not isinstance(synchronization[0], dict)
     ):
         return False
 
@@ -927,10 +927,10 @@ def _stream_can_drop_samples(stream_meta):
 
 
 def _jitter_removal(
-    streams,
-    threshold_seconds=1,
-    threshold_samples=500,
-    stream_headers=None,
+        streams,
+        threshold_seconds=1,
+        threshold_samples=500,
+        stream_headers=None,
 ):
     for stream_id, stream in streams.items():
         stream.effective_srate = 0  # will be recalculated if possible
@@ -945,7 +945,7 @@ def _jitter_removal(
             # dejittering because it compresses dropped-frame intervals and can shift
             # the segment start substantially earlier.
             if _stream_can_drop_samples(
-                None if stream_headers is None else stream_headers.get(stream_id)
+                    None if stream_headers is None else stream_headers.get(stream_id)
             ):
                 stream.segments.append((0, nsamples - 1))  # inclusive
                 if nsamples > 1: