From 815bb51ecfe9c0779f3603a48fc53780cf0c3113 Mon Sep 17 00:00:00 2001 From: Thomas Hardy Date: Thu, 28 Nov 2024 23:16:04 -0800 Subject: [PATCH] Linting fixes --- .../src/workflow/index.ts | 1 - packages/test/src/workflows/smorgasbord.ts | 13 ++++++++++--- 2 files changed, 10 insertions(+), 4 deletions(-) diff --git a/packages/interceptors-opentelemetry/src/workflow/index.ts b/packages/interceptors-opentelemetry/src/workflow/index.ts index 743cbfff0..e413ffc51 100644 --- a/packages/interceptors-opentelemetry/src/workflow/index.ts +++ b/packages/interceptors-opentelemetry/src/workflow/index.ts @@ -122,7 +122,6 @@ export class OpenTelemetryOutboundInterceptor implements WorkflowOutboundCallsIn }); } - public async startChildWorkflowExecution( input: StartChildWorkflowExecutionInput, next: Next diff --git a/packages/test/src/workflows/smorgasbord.ts b/packages/test/src/workflows/smorgasbord.ts index ac87fd2ea..b71c714dc 100644 --- a/packages/test/src/workflows/smorgasbord.ts +++ b/packages/test/src/workflows/smorgasbord.ts @@ -26,7 +26,7 @@ const { fakeProgress, queryOwnWf } = proxyActivities({ const { echo } = proxyLocalActivities({ startToCloseTimeout: '1m', cancellationType: ActivityCancellationType.WAIT_CANCELLATION_COMPLETED, -}) +}); export const stepQuery = defineQuery('step'); @@ -48,13 +48,20 @@ export async function smorgasbord(iteration = 0): Promise { 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)) {