Fix activity completion when thread interrupted flag is set

Author: sojanmathew

temporal-sdk/src/main/java/io/temporal/internal/worker/ActivityWorker.java

@@ -347,10 +347,9 @@ public Throwable wrapFailure(ActivityTask t, Throwable failure) {
      */
     private void executeGrpcCallWithInterruptHandling(Runnable grpcCall) {
       // Check if the current thread is interrupted before making gRPC calls
-      // If it is, we need to temporarily clear the flag to allow gRPC calls to succeed,
-      // then restore it after reporting. This handles the case where an activity
-      // catches InterruptedException, restores the interrupted flag, and continues to return a
-      // result.
+      // If it is, we need to temporarily clear the flag to allow gRPC calls to succeed,then restore it after reporting.
+      // This handles the case where an activity catches InterruptedException, restores the interrupted flag,
+      // and continues to return a result.
       // See: https://github.com/temporalio/sdk-java/issues/731
       boolean wasInterrupted = Thread.interrupted(); // This clears the flag
       try {

temporal-sdk/src/test/java/io/temporal/worker/InterruptedActivityCompletionValidationTest.java

@@ -24,12 +24,12 @@
 /**
  * Validation test for the interrupted activity completion fix.
  *
- * <p>This test demonstrates that the fix for https://github.com/temporalio/sdk-java/issues/731 is
- * working correctly. Before the fix, activities that returned with the interrupted flag set would
- * fail to report their results due to gRPC call failures.
+ * <p>This test demonstrates that the fix for https://github.com/temporalio/sdk-java/issues/731 is working correctly.
+ * Before the fix, activities that returned with the interrupted flag set would fail to report their results
+ * due to gRPC call failures.
  *
- * <p>The fix was applied in ActivityWorker.sendReply() method to temporarily clear the interrupted
- * flag during gRPC calls and restore it afterward.
+ * <p>The fix was applied in ActivityWorker.sendReply() method to temporarily clear the interrupted flag
+ * during gRPC calls and restore it afterward.
  */
 public class InterruptedActivityCompletionValidationTest {
 
@@ -59,9 +59,11 @@ public interface TestActivity {
   /**
    * This test validates that the fix is working by demonstrating that:
    *
-   * <p>1. An activity can set the interrupted flag and still return a result 2. The result is
-   * successfully reported to the Temporal server 3. The workflow completes with the expected result
-   * 4. The activity completion is properly recorded in the workflow history
+   * <p>
+   *   1. An activity can set the interrupted flag and still return a result
+   *   2. The result is successfully reported to the Temporal server
+   *   3. The workflow completes with the expected result
+   *   4. The activity completion is properly recorded in the workflow history
    *
    * <p>Before the fix: This test would fail with CancellationException during gRPC calls After the
    * fix: This test passes, proving activities can complete despite interrupted flag