fix(pubsub): missing credential provider on the PubSub Consume task (k…

…estra-io#280) close kestra-io#268
gorgias · Sep 4, 2023 · 13d96e3 · 13d96e3
1 parent 4d22b83
commit 13d96e3
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/src/main/java/io/kestra/plugin/gcp/pubsub/Consume.java b/src/main/java/io/kestra/plugin/gcp/pubsub/Consume.java
@@ -1,5 +1,6 @@
 package io.kestra.plugin.gcp.pubsub;
 
+import com.google.api.gax.core.FixedCredentialsProvider;
 import com.google.cloud.pubsub.v1.MessageReceiver;
 import com.google.cloud.pubsub.v1.Subscriber;
 import io.kestra.core.models.annotations.Example;
@@ -100,7 +101,9 @@ public Output run(RunContext runContext) throws Exception {
                     consumer.nack();
                 }
             };
-            var subscriber = Subscriber.newBuilder(subscriptionName, receiver).build();
+            var subscriber = Subscriber.newBuilder(subscriptionName, receiver)
+                .setCredentialsProvider(FixedCredentialsProvider.create(this.credentials(runContext)))
+                .build();
             subscriber.startAsync().awaitRunning();
 
             while (!this.ended(total, started)) {