Merge pull request #1 from brewkode/fix/on-start-error-handling

fix: handle error and return gracefully during failures
kube-logging · Jan 5, 2024 · 6e88fd7 · 6e88fd7
2 parents 76a1920 + 89fa7e9
commit 6e88fd7
Showing 1 changed file with 15 additions and 10 deletions.
diff --git a/lib/fluent/plugin/out_gcs.rb b/lib/fluent/plugin/out_gcs.rb
@@ -105,16 +105,21 @@ def configure(conf)
     end
 
     def start
-      @gcs = Google::Cloud::Storage.new(
-        project: @project,
-        keyfile: @credentials,
-        retries: @client_retries,
-        timeout: @client_timeout
-      )
-      @gcs_bucket = @gcs.bucket(@bucket)
-
-      ensure_bucket
-      super
+      begin
+        @gcs = Google::Cloud::Storage.new(
+          project: @project,
+          keyfile: @credentials,
+          retries: @client_retries,
+          timeout: @client_timeout
+        )
+        @gcs_bucket = @gcs.bucket(@bucket)
+
+        ensure_bucket
+        super
+      rescue => e
+        log.warn "GCS output plugin initialization error: #{e.message}"
+        log.warn "#{e.full_message()}"
+      end
     end
 
     def format(tag, time, record)