X-Git-Url: http://woldlab.caltech.edu/gitweb/?p=htsworkflow.git;a=blobdiff_plain;f=htsworkflow%2Fpipelines%2Fdesplit_fastq.py;h=c9947a2ef2317b0a05f7c36e966eb152949fc1f3;hp=83a995588079f34088e5b07ac7d098bfb08b3072;hb=10c9e90168dae0d301ee6b6ba4afd99b295782f5;hpb=11f2361eee320080ab8c18fe65e5da87da52a942

diff --git a/htsworkflow/pipelines/desplit_fastq.py b/htsworkflow/pipelines/desplit_fastq.py
index 83a9955..c9947a2 100644
--- a/htsworkflow/pipelines/desplit_fastq.py
+++ b/htsworkflow/pipelines/desplit_fastq.py
@@ -89,7 +89,9 @@ class DesplitFastq(object):
         This is here so we can run via threading/multiprocessing APIs
         """
         state = SEQ_HEADER
+        files_read = 0
         for stream in self.sources:
+            files_read += 1
             for line in stream:
                 line = line.rstrip()
                 if state == SEQ_HEADER:
@@ -106,6 +108,8 @@ class DesplitFastq(object):
                     state = SEQ_HEADER
                 self.destination.write(os.linesep)
 
+        if files_read == 0:
+            raise RuntimeError("No files processed")
 
 if __name__ == "__main__":
     main()