diff --git a/temporal-testing/src/main/java/io/temporal/testing/TestActivityEnvironmentInternal.java b/temporal-testing/src/main/java/io/temporal/testing/TestActivityEnvironmentInternal.java index a97841389..1760edf5c 100644 --- a/temporal-testing/src/main/java/io/temporal/testing/TestActivityEnvironmentInternal.java +++ b/temporal-testing/src/main/java/io/temporal/testing/TestActivityEnvironmentInternal.java @@ -363,17 +363,13 @@ private Result executeActivity( localActivity)); try { - // 10 seconds is just a "reasonable" wait to not make an infinite waiting - return activityFuture.get(10, TimeUnit.SECONDS); + return activityFuture.get(); } catch (InterruptedException e) { Thread.currentThread().interrupt(); throw new RuntimeException(e); } catch (ExecutionException e) { log.error("Exception during processing of activity task"); throw new RuntimeException(e); - } catch (TimeoutException e) { - log.error("Timeout trying execute activity task {}", activityTask); - throw new RuntimeException(e); } }