diff --git a/reporting/ReportingETL.cpp b/reporting/ReportingETL.cpp index 0ca3b765..75c48e8e 100644 --- a/reporting/ReportingETL.cpp +++ b/reporting/ReportingETL.cpp @@ -443,6 +443,7 @@ ReportingETL::runETLPipeline(uint32_t startSequence, int numExtractors) { std::optional fetchResponse{ getNext(currentSequence)->pop()}; + ++currentSequence; // if fetchResponse is an empty optional, the extracter thread // has stopped and the transformer should stop as well if (!fetchResponse)