From bd71443e8ea5710fb9570ebc28535bdffd73720f Mon Sep 17 00:00:00 2001 From: Michael Xu Date: Thu, 18 Apr 2024 16:00:18 -0400 Subject: [PATCH] update comment --- src/connector/src/sink/snowflake.rs | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/connector/src/sink/snowflake.rs b/src/connector/src/sink/snowflake.rs index ac75e3f583644..d61273a8636a4 100644 --- a/src/connector/src/sink/snowflake.rs +++ b/src/connector/src/sink/snowflake.rs @@ -241,7 +241,7 @@ impl SnowflakeSinkWriter { /// note: should *only* be called iff after a new epoch begins, /// and `streaming_upload` being called the first time. /// i.e., lazily initialization of the internal `streaming_uploader`. - /// plus, this function is *pure*, the `&mut self` is to make rustc (and tokio) happy. + /// plus, this function is *pure*, the `&mut self` here is to make rustc (and tokio) happy. async fn new_streaming_uploader(&mut self) -> Result<(Box, String)> { let file_suffix = self.file_suffix(); let path = generate_s3_file_name(self.s3_client.s3_path(), &file_suffix);