pub async fn start_tx_checkpoint_commit_task<S>(
state: S,
metrics: IndexerMetrics,
tx_indexing_receiver: Receiver<CheckpointDataToCommit>,
cancel: CancellationToken,
next_checkpoint_sequence_number: CheckpointSequenceNumber,
end_checkpoint_opt: Option<CheckpointSequenceNumber>,
) -> IndexerResult<()>