🐛 when skipping files

dionhaefner · Oct 10, 2019 · 7cdd7f3 · 7cdd7f3
1 parent 9aca05d
commit 7cdd7f3
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/fowd/cdip.py b/fowd/cdip.py
@@ -240,6 +240,13 @@ def handle_result(i, result, pbar):
 
     logger.info('Processing done')
 
+    # remove skipped files
+    wave_records = [subrecord for subrecord in wave_records if subrecord is not None]
+
+    if not wave_records:
+        logger.warn('Processed no files - no output to write')
+        return
+
     # concatenate subrecords
     wave_records = {
         key: np.concatenate([subrecord[key] for subrecord in wave_records])