diff --git a/hystrix-core/src/main/java/com/netflix/hystrix/strategy/concurrency/HystrixContextFunc2.java b/hystrix-core/src/main/java/com/netflix/hystrix/strategy/concurrency/HystrixContextFunc2.java
index 4fffafe4d..aa84b6317 100644
--- a/hystrix-core/src/main/java/com/netflix/hystrix/strategy/concurrency/HystrixContextFunc2.java
+++ b/hystrix-core/src/main/java/com/netflix/hystrix/strategy/concurrency/HystrixContextFunc2.java
@@ -64,7 +64,7 @@ public Subscription call() throws Exception {
                     // set the state of this thread to that of its parent
                     HystrixRequestContext.setContextOnCurrentThread(parentThreadState);
                     // execute actual Func2 with the state of the parent
-                    return actual.call(t1Holder.get(), t2Holder.get());
+                    return actual.call(new HystrixContextScheduler(concurrencyStrategy, t1Holder.get()), t2Holder.get());
                 } finally {
                     // restore this thread back to its original state
                     HystrixRequestContext.setContextOnCurrentThread(existingState);