@@ -19,7 +19,7 @@ public TaskActivityExecutor(
1919 this .logger = logger ;
2020 }
2121
22- public String execute (String taskName , String input , String taskExecutionKey ) throws Throwable {
22+ public String execute (String taskName , String input , int taskId ) throws Throwable {
2323 TaskActivityFactory factory = this .activityFactories .get (taskName );
2424 if (factory == null ) {
2525 throw new IllegalStateException (
@@ -32,7 +32,7 @@ public String execute(String taskName, String input, String taskExecutionKey) th
3232 String .format ("The task factory '%s' returned a null TaskActivity object." , taskName ));
3333 }
3434
35- TaskActivityContextImpl context = new TaskActivityContextImpl (taskName , input , taskExecutionKey );
35+ TaskActivityContextImpl context = new TaskActivityContextImpl (taskName , input );
3636
3737 // Unhandled exceptions are allowed to escape
3838 Object output = activity .run (context );
@@ -44,29 +44,21 @@ public String execute(String taskName, String input, String taskExecutionKey) th
4444 }
4545
4646 private class TaskActivityContextImpl implements TaskActivityContext {
47- private final String taskExecutionKey ;
4847 private final String name ;
4948 private final String rawInput ;
50-
5149
5250 private final DataConverter dataConverter = TaskActivityExecutor .this .dataConverter ;
5351
54- public TaskActivityContextImpl (String activityName , String rawInput , String taskExecutionKey ) {
52+ public TaskActivityContextImpl (String activityName , String rawInput ) {
5553 this .name = activityName ;
5654 this .rawInput = rawInput ;
57- this .taskExecutionKey = taskExecutionKey ;
5855 }
5956
6057 @ Override
6158 public String getName () {
6259 return this .name ;
6360 }
6461
65- @ Override
66- public String getTaskExecutionKey () {
67- return this .taskExecutionKey ;
68- }
69-
7062 @ Override
7163 public <T > T getInput (Class <T > targetType ) {
7264 if (this .rawInput == null ) {
0 commit comments