def compress_snapshots(self, directory='output', directory_out='', snapshot_index_limits=[0, 600], thread_number=1):
    '\n        Compress all snapshots in input directory.\n\n        Parameters\n        ----------\n        directory : str : directory of snapshots\n        directory_out : str : directory to write compressed snapshots\n        snapshot_index_limits : list : min and max snapshot indices to compress\n        syncronize : bool : whether to synchronize parallel tasks,\n            wait for each thread bundle to complete before starting new bundle\n        '
    snapshot_indices = np.arange(snapshot_index_limits[0], (snapshot_index_limits[1] + 1))
    args_list = [(directory, directory_out, snapshot_index) for snapshot_index in snapshot_indices]
    ut.io.run_in_parallel(self.compress_snapshot, args_list, thread_number=thread_number)
Compress all snapshots in input directory.

Parameters
----------
directory : str : directory of snapshots
directory_out : str : directory to write compressed snapshots
snapshot_index_limits : list : min and max snapshot indices to compress
syncronize : bool : whether to synchronize parallel tasks,
    wait for each thread bundle to complete before starting new bundle
def compress_snapshots(self, directory='output', directory_out=, snapshot_index_limits=[0, 600], thread_number=1):
    '\n        Compress all snapshots in input directory.\n\n        Parameters\n        ----------\n        directory : str : directory of snapshots\n        directory_out : str : directory to write compressed snapshots\n        snapshot_index_limits : list : min and max snapshot indices to compress\n        syncronize : bool : whether to synchronize parallel tasks,\n            wait for each thread bundle to complete before starting new bundle\n        '
    snapshot_indices = np.arange(snapshot_index_limits[0], (snapshot_index_limits[1] + 1))
    args_list = [(directory, directory_out, snapshot_index) for snapshot_index in snapshot_indices]
    ut.io.run_in_parallel(self.compress_snapshot, args_list, thread_number=thread_number)