inc current sequence in load thread

This commit is contained in:
CJ Cobb
2021-03-24 13:27:46 -04:00
parent 3062b5e678
commit c74f9654af

View File

@@ -443,6 +443,7 @@ ReportingETL::runETLPipeline(uint32_t startSequence, int numExtractors)
{
std::optional<org::xrpl::rpc::v1::GetLedgerResponse> 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)