Skip to content

Commit

Permalink
Refactor test tracer for consistency
Browse files Browse the repository at this point in the history
  • Loading branch information
Quinn-With-Two-Ns committed Dec 6, 2024
1 parent 7ed7c9d commit b6e8ba6
Show file tree
Hide file tree
Showing 3 changed files with 11 additions and 11 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -65,9 +65,9 @@ public void asyncOperationImmediatelyCancelled() {
.setExpected(
"interceptExecuteWorkflow " + SDKTestWorkflowRule.UUID_REGEXP,
"newThread workflow-method",
"executeNexusOperation TestNexusService1.operation",
"startNexusOperation TestNexusService1.operation",
"cancelNexusOperation TestNexusService1.operation");
"executeNexusOperation TestNexusService1 operation",
"startNexusOperation TestNexusService1 operation",
"cancelNexusOperation TestNexusService1 operation");
}

@Test
Expand All @@ -85,13 +85,13 @@ public void asyncOperationCancelled() {
.setExpected(
"interceptExecuteWorkflow " + SDKTestWorkflowRule.UUID_REGEXP,
"newThread workflow-method",
"executeNexusOperation TestNexusService1.operation",
"startNexusOperation TestNexusService1.operation",
"executeNexusOperation TestNexusService1 operation",
"startNexusOperation TestNexusService1 operation",
"interceptExecuteWorkflow " + SDKTestWorkflowRule.UUID_REGEXP,
"registerSignalHandlers unblock",
"newThread workflow-method",
"await await",
"cancelNexusOperation TestNexusService1.operation");
"cancelNexusOperation TestNexusService1 operation");
}

public static class TestNexus implements TestWorkflows.TestWorkflow1 {
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -70,8 +70,8 @@ public void syncClientOperationSuccess() {
"interceptExecuteWorkflow " + SDKTestWorkflowRule.UUID_REGEXP,
"registerUpdateHandlers update",
"newThread workflow-method",
"executeNexusOperation TestNexusService1.operation",
"startNexusOperation TestNexusService1.operation");
"executeNexusOperation TestNexusService1 operation",
"startNexusOperation TestNexusService1 operation");
// Test metrics all tasks should have
Map<String, String> nexusWorkerTags =
ImmutableMap.<String, String>builder()
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -197,7 +197,7 @@ public <R> ChildWorkflowOutput<R> executeChildWorkflow(ChildWorkflowInput<R> inp
public <R> ExecuteNexusOperationOutput<R> executeNexusOperation(
ExecuteNexusOperationInput<R> input) {
if (!WorkflowUnsafe.isReplaying()) {
trace.add("executeNexusOperation " + input.getService() + "." + input.getOperation());
trace.add("executeNexusOperation " + input.getService() + " " + input.getOperation());
}
return next.executeNexusOperation(input);
}
Expand Down Expand Up @@ -499,7 +499,7 @@ public StartOperationOutput startOperation(StartOperationInput input)
trace.add(
"startNexusOperation "
+ input.getOperationContext().getService()
+ "."
+ " "
+ input.getOperationContext().getOperation());
return next.startOperation(input);
}
Expand All @@ -509,7 +509,7 @@ public CancelOperationOutput cancelOperation(CancelOperationInput input) {
trace.add(
"cancelNexusOperation "
+ input.getOperationContext().getService()
+ "."
+ " "
+ input.getOperationContext().getOperation());
return next.cancelOperation(input);
}
Expand Down

0 comments on commit b6e8ba6

Please sign in to comment.