From 665e1ae7276fbc039372f8d5fc996327102ce231 Mon Sep 17 00:00:00 2001 From: Robin Tang Date: Sun, 15 Sep 2024 22:19:43 -0700 Subject: [PATCH] Add TODO. --- clients/snowflake/writes.go | 2 ++ 1 file changed, 2 insertions(+) diff --git a/clients/snowflake/writes.go b/clients/snowflake/writes.go index 7d9061535..c69e893f6 100644 --- a/clients/snowflake/writes.go +++ b/clients/snowflake/writes.go @@ -17,6 +17,7 @@ func (s *Store) Append(tableData *optimization.TableData, _ bool) error { var err error for i := 0; i < maxRetries; i++ { if i > 0 { + // TODO: remove if IsAuthExpiredError(err) { slog.Warn("Authentication has expired, will reload the Snowflake store and retry appending", slog.Any("err", err)) if connErr := s.reestablishConnection(); connErr != nil { @@ -49,6 +50,7 @@ func (s *Store) Merge(tableData *optimization.TableData) error { var err error for i := 0; i < maxRetries; i++ { if i > 0 { + // TODO: Remove if IsAuthExpiredError(err) { slog.Warn("Authentication has expired, will reload the Snowflake store and retry merging", slog.Any("err", err)) if connErr := s.reestablishConnection(); connErr != nil {