fix spanner change record test

Author: yoshidan

.github/workflows/ci.yaml

@@ -43,8 +43,9 @@ jobs:
           ref: ${{ github.event.pull_request.head.ref }}
           repository: ${{github.event.pull_request.head.repo.full_name}}
       - name: cargo-deny
-        uses: EmbarkStudios/cargo-deny-action@v1
+        uses: EmbarkStudios/cargo-deny-action@v2
         with:
+          rust-version: "1.88.0"
           arguments: --workspace --all-features
   foundation:
     name: foundation

spanner/src/statement.rs

@@ -211,7 +211,7 @@ impl ToKind for ::prost_types::Timestamp {
     fn to_kind(&self) -> Kind {
         // The protobuf timestamp type should be formatted in RFC3339
         // See here for more details: https://docs.rs/prost-types/latest/prost_types/struct.Timestamp.html
-        let rfc3339 = format!("{}", self);
+        let rfc3339 = format!("{self}");
         rfc3339.to_kind()
     }
 

spanner/tests/change_stream_test.rs

@@ -166,13 +166,13 @@ async fn test_read_change_stream() {
     // Create Change Stream
     let cred = google_cloud_auth::credentials::CredentialsFile::new().await.unwrap();
     let project = cred.project_id.unwrap();
-    let db = format!("projects/{}/instances/test-instance/databases/local-database", project);
+    let db = format!("projects/{project}/instances/test-instance/databases/local-database2");
     let admin_client = admin::client::Client::new(AdminClientConfig {
         environment: create_environment().await,
     })
     .await
     .unwrap();
-    let _ = admin_client
+    let result = admin_client
         .database()
         .update_database_ddl(
             UpdateDatabaseDdlRequest {
@@ -185,8 +185,16 @@ async fn test_read_change_stream() {
             None,
         )
         .await;
-
-    sleep(Duration::from_secs(20)).await;
+    match result {
+        Ok(mut res) => {
+            let op = res.wait(None).await;
+            match op {
+                Ok(_) => tracing::info!("create change stream success"),
+                Err(e) => panic!("create change stream failed: {e:?}"),
+            }
+        }
+        Err(e) => panic!("create change stream failed: {e:?}"),
+    }
 
     let now = OffsetDateTime::now_utc();