def retryAsyncOp()

in connector/src/main/scala/com/microsoft/kusto/spark/utils/ExtendedKustoClient.scala [504:527]

• 24 lines of code
• 1 McCabe index (conditional complexity)

  def retryAsyncOp(
                    database: String,
                    cmd: String,
                    crp: ClientRequestProperties,
                    timeout: FiniteDuration,
                    cmdToTrace: String,
                    cmdName: String,
                    requestId: String): Option[KustoResultSetTable] = {
    KDSU.retryApplyFunction(
      i => {
        val operation = executeEngine(database, cmd, cmdToTrace, newIncrementedCrp(Some(crp), cmdName, i)).getPrimaryResults
        KDSU.verifyAsyncCommandCompletion(
          engineClient,
          database,
          operation,
          samplePeriod = KustoConstants.DefaultPeriodicSamplePeriod,
          timeout,
          cmdToTrace,
          myName,
          requestId)
      },
      retryConfigAsyncOp,
      cmdToTrace)
  }