Skip to content

Commit b8315f3

Browse files
committed
update flaky test
1 parent 918424b commit b8315f3

2 files changed

Lines changed: 18 additions & 2 deletions

File tree

endtoendtests/src/main/java/com/functions/ParallelFunctions.java

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -86,7 +86,7 @@ public Object parallelAnyOf(
8686
List<Task<?>> tasks = new ArrayList<>();
8787
tasks.add(ctx.callActivity("AppendHappy", "AnyOf1", taskOptions, String.class));
8888
tasks.add(ctx.callActivity("AppendHappy", "AnyOf2", String.class));
89-
tasks.add(ctx.callActivity("AppendHappy", 1, Integer.class));
89+
tasks.add(ctx.callActivity("AppendInt", 1, Integer.class));
9090
return ctx.anyOf(tasks).await().await();
9191
}
9292

@@ -127,6 +127,14 @@ public List<String> parallelCatchException(
127127
return null;
128128
}
129129

130+
@FunctionName("AppendInt")
131+
public int appendInt(
132+
@DurableActivityTrigger(name = "value") int value,
133+
final ExecutionContext context) {
134+
context.getLogger().info("AppendInt: " + value);
135+
return value + 1;
136+
}
137+
130138
@FunctionName("AlwaysException")
131139
public String alwaysException(
132140
@DurableActivityTrigger(name = "name") String name,

samples-azure-functions/src/main/java/com/functions/ParallelFunctions.java

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -86,7 +86,7 @@ public Object parallelAnyOf(
8686
List<Task<?>> tasks = new ArrayList<>();
8787
tasks.add(ctx.callActivity("AppendHappy", "AnyOf1", taskOptions, String.class));
8888
tasks.add(ctx.callActivity("AppendHappy", "AnyOf2", String.class));
89-
tasks.add(ctx.callActivity("AppendHappy", 1, Integer.class));
89+
tasks.add(ctx.callActivity("AppendInt", 1, Integer.class));
9090
return ctx.anyOf(tasks).await().await();
9191
}
9292

@@ -127,6 +127,14 @@ public List<String> parallelCatchException(
127127
return null;
128128
}
129129

130+
@FunctionName("AppendInt")
131+
public int appendInt(
132+
@DurableActivityTrigger(name = "value") int value,
133+
final ExecutionContext context) {
134+
context.getLogger().info("AppendInt: " + value);
135+
return value + 1;
136+
}
137+
130138
@FunctionName("AlwaysException")
131139
public String alwaysException(
132140
@DurableActivityTrigger(name = "name") String name,

0 commit comments

Comments
 (0)