Add check

siri-varma · siri-varma · commit a05165071434 · 2025-05-07T09:24:00.000-07:00
Signed-off-by: siri-varma &lt;siri.varma@outlook.com&gt;
diff --git a/client/src/main/java/com/microsoft/durabletask/DurableTaskGrpcWorker.java b/client/src/main/java/com/microsoft/durabletask/DurableTaskGrpcWorker.java
@@ -65,7 +65,7 @@ public final class DurableTaskGrpcWorker implements AutoCloseable {
         this.sidecarClient = TaskHubSidecarServiceGrpc.newBlockingStub(sidecarGrpcChannel);
         this.dataConverter = builder.dataConverter != null ? builder.dataConverter : new JacksonDataConverter();
         this.maximumTimerInterval = builder.maximumTimerInterval != null ? builder.maximumTimerInterval : DEFAULT_MAXIMUM_TIMER_INTERVAL;
-        this.workerPool = builder.executorService;
+        this.workerPool = builder.executorService != null ? builder.executorService : Executors.newCachedThreadPool();
     }
 
     /**

Original file line number	Diff line number	Diff line change
`@@ -65,7 +65,7 @@ public final class DurableTaskGrpcWorker implements AutoCloseable {`
`65`	`65`	`this.sidecarClient = TaskHubSidecarServiceGrpc.newBlockingStub(sidecarGrpcChannel);`
`66`	`66`	`this.dataConverter = builder.dataConverter != null ? builder.dataConverter : new JacksonDataConverter();`
`67`	`67`	`this.maximumTimerInterval = builder.maximumTimerInterval != null ? builder.maximumTimerInterval : DEFAULT_MAXIMUM_TIMER_INTERVAL;`
`68`		`- this.workerPool = builder.executorService;`
	`68`	`+ this.workerPool = builder.executorService != null ? builder.executorService : Executors.newCachedThreadPool();`
`69`	`69`	`}`
`70`	`70`
`71`	`71`	`/**`