Switch to nanoseconds

Signed-off-by: Ramona Luczkiewicz <rluczkiewicz@wayfair.com>
tremor-rs · May 4, 2022 · 75a4abd · 75a4abd
1 parent 33ef2ba
commit 75a4abd
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/src/connectors/impls/gbq/writer/sink.rs b/src/connectors/impls/gbq/writer/sink.rs
@@ -365,7 +365,7 @@ impl Sink for GbqSink {
 
         let append_response = client
             .append_rows(stream::iter(vec![request]))
-            .timeout(Duration::from_secs(self.config.request_timeout))
+            .timeout(Duration::from_nanos(self.config.request_timeout))
             .await;
 
         let append_response = if let Ok(append_response) = append_response {
@@ -379,7 +379,7 @@ impl Sink for GbqSink {
         if let Ok(x) = append_response?
             .into_inner()
             .next()
-            .timeout(Duration::from_secs(self.config.request_timeout))
+            .timeout(Duration::from_nanos(self.config.request_timeout))
             .await
         {
             match x {
@@ -407,7 +407,7 @@ impl Sink for GbqSink {
             .domain_name("bigquerystorage.googleapis.com");
 
         let channel = Channel::from_static("https://bigquerystorage.googleapis.com")
-            .connect_timeout(Duration::from_secs(self.config.connect_timeout))
+            .connect_timeout(Duration::from_nanos(self.config.connect_timeout))
             .tls_config(tls_config)?
             .connect()
             .await?;