Skip to content

Commit

Permalink
Linting fixes
Browse files Browse the repository at this point in the history
  • Loading branch information
THardy98 committed Dec 3, 2024
1 parent 7564e30 commit 815bb51
Show file tree
Hide file tree
Showing 2 changed files with 10 additions and 4 deletions.
1 change: 0 additions & 1 deletion packages/interceptors-opentelemetry/src/workflow/index.ts
Original file line number Diff line number Diff line change
Expand Up @@ -122,7 +122,6 @@ export class OpenTelemetryOutboundInterceptor implements WorkflowOutboundCallsIn
});
}


public async startChildWorkflowExecution(
input: StartChildWorkflowExecutionInput,
next: Next<WorkflowOutboundCallsInterceptor, 'startChildWorkflowExecution'>
Expand Down
13 changes: 10 additions & 3 deletions packages/test/src/workflows/smorgasbord.ts
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,7 @@ const { fakeProgress, queryOwnWf } = proxyActivities<typeof activities>({
const { echo } = proxyLocalActivities<typeof activities>({
startToCloseTimeout: '1m',
cancellationType: ActivityCancellationType.WAIT_CANCELLATION_COMPLETED,
})
});

export const stepQuery = defineQuery<number>('step');

Expand All @@ -48,13 +48,20 @@ export async function smorgasbord(iteration = 0): Promise<void> {
await childWf.result();
})();

const localActivityPromise = echo("local-activity");
const localActivityPromise = echo('local-activity');

if (iteration === 0) {
CancellationScope.current().cancel();
}

await Promise.all([activityPromise, queryActPromise, timerPromise, childWfPromise, localActivityPromise, condition(() => unblocked)]);
await Promise.all([
activityPromise,
queryActPromise,
timerPromise,
childWfPromise,
localActivityPromise,
condition(() => unblocked),
]);
});
} catch (e) {
if (iteration !== 0 || !isCancellation(e)) {
Expand Down

0 comments on commit 815bb51

Please sign in to comment.