You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
"message": "feat: dataconnect: DataConnectOperationException added to support partial errors (#6794)\n\nThis PR adds the `DataConnectOperationException` class, a subclass of\nthe previously-existing `DataConnectException` class. This new\n`DataConnectOperationException` class is thrown by invocations of\n`QueryRef.execute()` and `MutationRef.execute()` in the case where a\nresponse _is_ received from the backend, but the response indicates that\nthe operation could not be executed to completion, including the case\nthat the client SDK fails to decode the response to a higher-level\nobject. Other kinds of errors, such as networking errors, will still be\nreported as they were previously.\n\nClient code can catch `DataConnectOperationException` and check its\n`response` property to get details about any errors that occurred and\nany data that was received. If the data was able to be decoded, despite\nthe errors, then it will be available. Also the \"raw\" data (a\n`Map<String, Any?>`) property will give access to the raw, undecoded\ndata, if any was sent from the backend.\n\nThis feature is intended to support \"partial errors\", where an operation\ncan partially succeed and partially fail, and the client application\nwants to take some special behavior in the case of a partial success.\n\nFor example, suppose this database schema and connector definition:\n\n```\ntype Person @table {\n name: String!\n}\n\n# Notice how both \"inserts\" use the same ID; this means that one of them\n# will necessarily fail because you can't have two rows with the same ID.\nmutation InsertMultiplePeople($id: UUID!, $name1: String!, $name2: String!) {\n person1: person_insert(data: { id: $id, name: $name1 })\n person2: person_insert(data: { id: $id, name: $name2 })\n}\n```\n\nHere is some code that handles the partial error that will occur if this\nmutation were to ever be executed:\n\n```kt\nimport com.google.firebase.dataconnect.DataConnectOperationException\nimport com.google.firebase.dataconnect.DataConnectOperationFailureResponse\nimport com.google.firebase.dataconnect.DataConnectPathSegment\nimport com.myapp.myconnector.InsertTwoFoosWithSameIdMutation.Data\n\nsuspend fun demo(id: UUID, connector: DemoConnector): Data {\n val result = connector.insertTwoFoosWithSameId.runCatching { execute(id) }\n result.onSuccess {\n println(\"Weird... inserting _both_ entries with ID $id succeeded 🤷\")\n return@demo it.data\n }\n\n val exception = result.exceptionOrNull()!!\n if (exception !is DataConnectOperationException) {\n throw exception\n }\n\n // Print warnings messages about which of \"foo1\" and \"foo2\" failed to\n // be inserted by the query. This information is gleaned from the list of\n // errors provided in the DataConnectOperationFailureResponse.\n val response: DataConnectOperationFailureResponse<*> = exception.response\n val errors = response.errors\n\n val error1 = errors.firstOrNull {\n it.path == listOf(DataConnectPathSegment.Field(\"person1\"))\n }\n if (error1 == null) {\n println(\"Inserting 1st entry with ID $id succeeded\")\n } else {\n println(\"Inserting 1st entry with ID $id failed: ${error1.message}\")\n }\n\n val error2 = errors.firstOrNull \n it.path == listOf(DataConnectPathSegment.Field(\"person2\"))\n }\n if (error2 == null) {\n println(\"Inserting 2nd entry with ID $id succeeded\")\n } else {\n println(\"Inserting 2nd entry with ID $id failed: ${error2.message}\")\n }\n\n // If decoding the response was actually successful, then return\n // the decoded response.\n val data = response.data as? Data\n if (data != null) {\n return data\n }\n\n throw exception\n}\n\n```",
"message": "[VertexAI] Bump timeout for error test (#6807)\n\nThe test `genStreamError_receivesError` is flaky due to timeout issues.\nBumping timeout to 10s.",
"message": "[Functions] Several functions improvements (#6796)\n\nThese improvements are both in the SDK itself, and in the code used for\nthe actual functions running in the cloud during integration testing:\n\nA summary of the changes is:\n- [Backend functions] Update the dependencies and node runtime version\n- [Backend functions] Add logging in case the client does not support\nstreaming\n- [SDK] Use a more robust handle of the media type\n- [SDK] Fix issue introduced in #6773 that missed a return in case of\nerror\n- [SDK] Other minor code fixes\n\nb/404814020",
"message": "fix(functions): use notifyError() instead of throwing (#6773)\n\nThrowing inside the `PublisherStream` causes a Runtime exception that\ncan't be caught in the call site.\nInstead, we should use `notifyError()` so that the error can be caught\nin the `Subscriber#onError()` function.\n\nI tried to catch the exception using both of the code snippets below,\nbut none of them worked. (they both work with the changes in this PR):\n\n```kotlin\nfunctions.getHttpsCallable(\"nonExistentFunction\")\n .stream().asFlow()\n .catch {\n // Handle error for a 404 function\n }\n .collect {\n // ...\n }\n```\n\n```kotlin\ntry {\n functions.getHttpsCallable(\"nonExistentFunction\")\n .stream().asFlow()\n .collect {\n // ...\n }\n} catch(e: Exception) {\n // Handle error for a 404 function\n}\n```\n\nRuntime exception thrown:\n\n```\nFATAL EXCEPTION: OkHttp Dispatcher\n Process: com.google.samples.quickstart.functions, PID: 13321\n com.google.firebase.functions.FirebaseFunctionsException: Value <html><head> of type java.lang.String cannot be converted to JSONObject Unexpected Response:\n \n <html><head>\n <meta http-equiv=\"content-type\" content=\"text/html;charset=utf-8\">\n <title>404 Page not found</title>\n </head>\n <body text=#000000 bgcolor=#ffffff>\n <h1>Error: Page not found</h1>\n <h2>The requested URL was not found on this server.</h2>\n <h2></h2>\n </body></html>\n \n at com.google.firebase.functions.PublisherStream.validateResponse(PublisherStream.kt:316)\n at com.google.firebase.functions.PublisherStream.access$validateResponse(PublisherStream.kt:41)\n at com.google.firebase.functions.PublisherStream$startStreaming$1$4.onResponse(PublisherStream.kt:161)\n at okhttp3.RealCall$AsyncCall.execute(RealCall.java:203)\n at okhttp3.internal.NamedRunnable.run(NamedRunnable.java:32)\n at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1156)\n at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:651)\n at java.lang.Thread.run(Thread.java:1119)\n```",
"message": "chore(functions): export reactive-streams as a transitive dependency (#6775)\n\nAlternative to #6774 - we'll keep that PR for a follow-up release.\n\nFor now, we're exposing the `reactive-streams` dependency to make sure\nit works out of the box for Java developers.",
"message": "Bidirectional Streaming Android (#6759)\n\nBidirectional streaming for android. Creates a bunch of helper classes\nfor the same. The main classes which handle the bidirectional streaming\nare LiveGenerativeModel and LiveSession\n\n---------\n\nCo-authored-by: VinayGuthal <[email protected]>\nCo-authored-by: Rodrigo Lazo Paz <[email protected]>\nCo-authored-by: Rodrigo Lazo <[email protected]>\nCo-authored-by: Daymon <[email protected]>\n",
"message": "[VertexAI] Log warning for unsupported model names (#6805)\n\nAdded a warning message to the initializers of GenerativeModel and\nImagenModel that is logged when the provided model name does not start\nwith the expected prefix (\"gemini-\" for GenerativeModel and \"imagen-\"\nfor ImagenModel). The warning message includes a link to the\ndocumentation for supported models.\n\nNote: No error is thrown in case the naming scheme is changed in the\nfuture, though we would want to update the logic/message at that time.\n\nRelated iOS PR https://github.com/firebase/firebase-ios-sdk/pull/14610",
"message": "[VertexAI] Remove redundant tests (#6762)\n\nThere is an extra copy of some tests inside ` test/.../common`\ndirectory. This change removes them, and in the process:\n\n- Adds missing tests to the correct test file\n- Gets rid of duplicated tests and test-util code\n- Adds an exception type for quota exceeded",
![github-actions[bot]](https://avatars.githubusercontent.com/in/15368?v=4&size=40){kind=avatar}
0 commit comments