Function commitAndBeginNew

packages/node-runtime/src/import/streaming-importer.ts:252–274

()

  }

  const commitAndBeginNew = () => {
    if (inTransaction) {
      db.exec('COMMIT')
      inTransaction = false
      logger?.perf('Commit transaction', totalMessageCount, BATCH_COMMIT_SIZE)

      if (totalMessageCount - lastCheckpointCount >= CHECKPOINT_INTERVAL) {
        doCheckpoint()
        logger?.perf('WAL checkpoint', totalMessageCount)
        lastCheckpointCount = totalMessageCount
      }

      onProgress({
        stage: 'importing',
        bytesRead: 0,
        totalBytes: 0,
        messagesProcessed: totalMessageCount,
        percentage: 100,
        message: '',
      })
    }
    beginTransaction()
  }

  beginTransaction()