chore(deps): Bump chrono from 0.4.30 to 0.4.31 (#12359)

Signed-off-by: dependabot[bot] <support@github.com> Signed-off-by: Runji Wang <wangrunji0408@163.com> Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com> Co-authored-by: Runji Wang <wangrunji0408@163.com> Co-authored-by: TennyZhuang <zty0826@gmail.com>
risingwavelabs · Sep 18, 2023 · c82fc9c · c82fc9c
1 parent cbdc1ac
commit c82fc9c
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 4 deletions.
diff --git a/Cargo.lock b/Cargo.lock
diff --git a/src/common/src/types/datetime.rs b/src/common/src/types/datetime.rs
@@ -324,7 +324,7 @@ impl Timestamp {
     }
 
     pub fn get_timestamp_nanos(&self) -> i64 {
-        self.0.timestamp_nanos()
+        self.0.timestamp_nanos_opt().unwrap()
     }
 
     pub fn with_micros(timestamp_micros: i64) -> Result<Self> {

diff --git a/src/connector/src/source/google_pubsub/source/message.rs b/src/connector/src/source/google_pubsub/source/message.rs
@@ -50,7 +50,7 @@ impl From<TaggedReceivedMessage> for SourceMessage {
                     _ => Some(payload),
                 }
             },
-            offset: timestamp.timestamp_nanos().to_string(),
+            offset: timestamp.timestamp_nanos_opt().unwrap().to_string(),
             split_id,
             meta: SourceMeta::GooglePubsub(GooglePubsubMeta {
                 timestamp: Some(timestamp.timestamp_millis()),