Ok well now that was easy. PartitionExecutor.executeSQLStmtBatch() will notify remote sites that we are done with their partitions whenever we're at the final task of a dtxn. We can do this even if the markov model estimations are not enabled