Can't handle RateLimitException

[daniatitienei]

I exceeded the quota, but when I try to catch the error it crashes. Does anyone have an idea how can I catch this error?

`
suspend fun sendStream(
messages: List,
tone: String,
chatRoomId: Int,
query: String
): Flow {
val messageList = messages.map { message ->
message.copy(
content = query
.replace("$tone", tone)
.replace("$message", message.content)
)
}

    val chatCompletionRequest = ChatCompletionRequest(
        model = ModelId("gpt-3.5-turbo"),
        messages = messageList.toChatMessages(),
        temperature = 0.4
    )

    return try {
        openAi.chatCompletions(chatCompletionRequest) ?: emptyFlow()
    } catch (e: RateLimitException) {
        emptyFlow()
    } catch (e: OpenAIAPIException) {
        emptyFlow()
    }
}

`

Response:
com.aallam.openai.api.exception.RateLimitException: You exceeded your current quota, please check your plan and billing details. at com.aallam.openai.client.internal.http.HttpTransport.openAIAPIException(HttpTransport.kt:64) at com.aallam.openai.client.internal.http.HttpTransport.handleException(HttpTransport.kt:48) at com.aallam.openai.client.internal.http.HttpTransport.perform(HttpTransport.kt:34) at com.aallam.openai.client.internal.http.HttpTransport$perform$2.invokeSuspend(Unknown Source:15) at kotlin.coroutines.jvm.internal.BaseContinuationImpl.resumeWith(ContinuationImpl.kt:33) at kotlinx.coroutines.DispatchedTask.run(DispatchedTask.kt:104) at kotlinx.coroutines.internal.LimitedDispatcher$Worker.run(LimitedDispatcher.kt:115) at kotlinx.coroutines.scheduling.TaskImpl.run(Tasks.kt:100) at kotlinx.coroutines.scheduling.CoroutineScheduler.runSafely(CoroutineScheduler.kt:584) at kotlinx.coroutines.scheduling.CoroutineScheduler$Worker.executeTask(CoroutineScheduler.kt:793) at kotlinx.coroutines.scheduling.CoroutineScheduler$Worker.runWorker(CoroutineScheduler.kt:697) at kotlinx.coroutines.scheduling.CoroutineScheduler$Worker.run(CoroutineScheduler.kt:684) Suppressed: kotlinx.coroutines.internal.DiagnosticCoroutineContextException: [StandaloneCoroutine{Cancelling}@a54c387, Dispatchers.IO] Caused by: io.ktor.client.plugins.ClientRequestException: Client request(POST https://api.openai.com/v1/chat/completions) invalid: 429 . Text: "{ "error": { "message": "You exceeded your current quota, please check your plan and billing details.", "type": "insufficient_quota", "param": null, "code": "insufficient_quota" } } " at io.ktor.client.plugins.DefaultResponseValidationKt$addDefaultResponseValidation$1$1.invokeSuspend(DefaultResponseValidation.kt:54) at kotlin.coroutines.jvm.internal.BaseContinuationImpl.resumeWith(ContinuationImpl.kt:33) at kotlinx.coroutines.DispatchedTask.run(DispatchedTask.kt:106) ... 6 more

[aallam]

Hello @daniatitienei, I believe the problem lies in your approach to error handling. Currently, you're catching exceptions during your flow instantiation, but you should instead be catching them at collect (or by using catch).

[daniatitienei]

Oh, I forgot that 😂. Thank you so much!