Skip to content

Commit 87278da

Browse files
committed
Check if FileFetcher is done for early stop on empty queue (fix for PR11985)
1 parent e235636 commit 87278da

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

Detectors/CTF/workflow/src/CTFReaderSpec.cxx

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -228,7 +228,7 @@ void CTFReaderSpec::run(ProcessingContext& pc)
228228
if (mCTFCounter >= mInput.maxTFs || (!mInput.ctfIDs.empty() && mSelIDEntry >= mInput.ctfIDs.size())) { // done
229229
LOG(info) << "All CTFs from selected range were injected, stopping";
230230
mRunning = false;
231-
} else if (mRunning && !mCTFTree && mFileFetcher->getNextFileInQueue().empty()) { // previous tree was done, can we read more?
231+
} else if (mRunning && !mCTFTree && mFileFetcher->getNextFileInQueue().empty() && !mFileFetcher->isRunning()) { // previous tree was done, can we read more?
232232
mRunning = false;
233233
}
234234

0 commit comments

Comments
 (0)