updates

orkes-io · Oct 10, 2022 · 804a9f6 · 804a9f6
1 parent 9a50ebd
commit 804a9f6
Show file tree

Hide file tree

Showing 13 changed files with 105 additions and 885 deletions.
diff --git a/build.gradle b/build.gradle
@@ -60,7 +60,7 @@ dependencies {
 
     implementation "org.slf4j:slf4j-api:${versions.slf4j}"
 
-    implementation 'io.orkes.conductor:orkes-conductor-common-protos:0.0.29'
+    implementation 'io.orkes.conductor:orkes-conductor-common-protos:0.0.33'
 
     //Grpc dependencies
     //implementation "io.grpc:grpc-okhttp:${versions.ioGRPC}"
@@ -193,7 +193,7 @@ configurations.implementation {
 
 spotless {
     java {
-        googleJavaFormat().aosp()
+        googleJavaFormat().aosp().reflowLongStrings(false)
         removeUnusedImports()
         importOrder('java', 'javax', 'org', 'com.netflix', 'io.orkes','', '\\#com.netflix', '\\#')
         licenseHeaderFile("$rootDir/licenseheader.txt")

diff --git a/src/main/java/io/orkes/conductor/client/automator/TaskRunnerConfigurer3.java b/src/main/java/io/orkes/conductor/client/automator/TaskRunnerConfigurer3.java
diff --git a/src/main/java/io/orkes/conductor/client/grpc/GrpcTaskWorker3.java b/src/main/java/io/orkes/conductor/client/grpc/GrpcTaskWorker3.java
diff --git a/src/main/java/io/orkes/conductor/client/grpc/GrpcWorkflowClient.java b/src/main/java/io/orkes/conductor/client/grpc/GrpcWorkflowClient.java
diff --git a/src/main/java/io/orkes/conductor/client/grpc/PooledPoller.java b/src/main/java/io/orkes/conductor/client/grpc/PooledPoller.java
@@ -236,7 +236,7 @@ public void onCompleted() {
 
     private void drain() {
         long didntGetMessageCount = lastAskedForMessageCount.get();
-        if(didntGetMessageCount > 0) {
+        if (didntGetMessageCount > 0) {
             log.info("Didn't get {} messages from server as expected", didntGetMessageCount);
             for (int i = 0; i < didntGetMessageCount; i++) {
                 this.saveTask(TaskPb.Task.newBuilder().setTaskId("NO_OP").build());

diff --git a/src/main/java/io/orkes/conductor/client/grpc/TaskPollObserver3.java b/src/main/java/io/orkes/conductor/client/grpc/TaskPollObserver3.java