for _, handle := range handles {
	ciphertext, ok := blockData.materializedCiphertexts[string(handle[:])]
	if !ok {
		return errors.New("ciphertext not found in cache")
	}

	log.Info("Persist ciphertext to state", "block number", blockNumber, "handle",
		handle.TerminalString(), "ciphertext length", len(ciphertext))

	putBytesToAddress(api, contractAddr, handle, ciphertext)
}

	// zero out queue ciphertexts
	for i := 0; i < int(ctCount); i++ {
		ctAddr := blockQueueStorageLayout(blockNumber, int64(i))
		metadata := bytesToMetadata(api.GetState(executorApi.contractStorageAddress, ctAddr.metadata))
		outputHandle := api.GetState(executorApi.contractStorageAddress, ctAddr.outputHandle)

		log.Debug("Reset computation LateCommit queue", "block number", blockNumber,
			"handle", outputHandle.TerminalString())

		handlesToMaterialize = append(handlesToMaterialize, outputHandle)
		api.SetState(executorApi.contractStorageAddress, ctAddr.metadata, zero)
		api.SetState(executorApi.contractStorageAddress, ctAddr.outputHandle, zero)
		api.SetState(executorApi.contractStorageAddress, ctAddr.firstOperand, zero)
		api.SetState(executorApi.contractStorageAddress, ctAddr.secondOperand, zero)
		if metadata.IsBigScalar {
			counter := new(big.Int)
			counter.SetBytes(ctAddr.bigScalarOperand[:])
			// max supported number 2048 is 2048
			for i := 0; i < 2048/256; i++ {
				api.SetState(executorApi.contractStorageAddress, common.BigToHash(counter), zero)
				counter.Add(counter, one)
			}
		}
	}