formatting & linting

Author: THardy98

packages/test/src/test-serialization-context.ts

@@ -2,6 +2,7 @@ import { randomUUID } from 'crypto';
 import { WorkflowClient, WorkflowFailedError } from '@temporalio/client';
 import { workflowInterceptorModules } from '@temporalio/testing';
 import { bundleWorkflowCode } from '@temporalio/worker';
+import { decodeOptionalSinglePayload } from '@temporalio/common/lib/internal-non-workflow';
 import { bundlerOptions, TestWorkflowEnvironment } from './helpers';
 import {
   makeConfigurableEnvironmentTestFn,
@@ -34,7 +35,6 @@ import {
 import { makeContextTrace } from './payload-converters/serialization-context-converter';
 import { echoTrace, heartbeatTrace } from './activities/serialization-context';
 import { throwAnError } from './activities';
-import { decodeOptionalSinglePayload } from '@temporalio/common/lib/internal-non-workflow';
 
 const converterPath = require.resolve('./payload-converters/serialization-context-converter');
 const dataConverter = { payloadConverterPath: converterPath, failureConverterPath: converterPath };
@@ -418,9 +418,7 @@ test('timer summary still serializes', async (t) => {
       execution: { workflowId },
     });
 
-    const timerStarted = resp.history?.events?.find(
-      (e) => e.timerStartedEventAttributes != null
-    );
+    const timerStarted = resp.history?.events?.find((e) => e.timerStartedEventAttributes != null);
 
     t.is(
       await decodeOptionalSinglePayload(
@@ -432,7 +430,6 @@ test('timer summary still serializes', async (t) => {
   });
 });
 
-
 test('workflow with many payload boundaries', async (t) => {
   const h = configurableHelpers(t, t.context.workflowBundle, t.context.env);
   const client = makeClient(t.context.env);
@@ -569,4 +566,4 @@ test('local activity failure observed by workflow carries local activity decode
     const message = await handle.result();
     t.is(message, `failure.decode.bound|${localAct}|failure.encode.bound|${localAct}|local-activity-failure`);
   });
-});
+});

packages/test/src/test-worker-heartbeats.ts

@@ -206,4 +206,4 @@ test('activity start heartbeat-details decode failure is encoded with activity s
       'failure.encode.bound|activity.worker-test.wfid.act-1.false|Failed to parse heartbeat details for activity act-1: Unknown encoding: '
     );
   });
-});
+});

packages/workflow/src/workflow.ts

@@ -85,10 +85,7 @@ function currentWorkflowSerializationContext(info: WorkflowInfo): WorkflowSerial
   };
 }
 
-function targetWorkflowSerializationContext(
-  info: WorkflowInfo,
-  workflowId: string
-): WorkflowSerializationContext {
+function targetWorkflowSerializationContext(info: WorkflowInfo, workflowId: string): WorkflowSerializationContext {
   return {
     type: 'workflow',
     namespace: info.namespace,
@@ -130,7 +127,10 @@ export function addDefaultWorkflowOptions<T extends Workflow>(
  */
 function timerNextHandler({ seq, durationMs, options }: TimerInput) {
   const activator = getActivator();
-  const payloadConverter = withPayloadConverterContext(activator.payloadConverter, currentWorkflowSerializationContext(activator.info));
+  const payloadConverter = withPayloadConverterContext(
+    activator.payloadConverter,
+    currentWorkflowSerializationContext(activator.info)
+  );
   return new Promise<void>((resolve, reject) => {
     const scope = CancellationScope.current();
     if (scope.consideredCancelled) {
@@ -1066,7 +1066,10 @@ export function makeContinueAsNewFunc<F extends Workflow>(
   };
 
   return (...args: Parameters<F>): Promise<never> => {
-    const payloadConverter = withPayloadConverterContext(activator.payloadConverter, currentWorkflowSerializationContext(info));
+    const payloadConverter = withPayloadConverterContext(
+      activator.payloadConverter,
+      currentWorkflowSerializationContext(info)
+    );
     const fn = composeInterceptors(activator.interceptors.outbound, 'continueAsNew', async (input) => {
       const { headers, args, options } = input;
       throw new ContinueAsNew({
@@ -1727,7 +1730,10 @@ export function upsertSearchAttributes(searchAttributes: SearchAttributes | Sear
  */
 export function upsertMemo(memo: Record<string, unknown>): void {
   const activator = assertInWorkflowContext('Workflow.upsertMemo(...) may only be used from a Workflow Execution.');
-  const payloadConverter = withPayloadConverterContext(activator.payloadConverter, currentWorkflowSerializationContext(activator.info));
+  const payloadConverter = withPayloadConverterContext(
+    activator.payloadConverter,
+    currentWorkflowSerializationContext(activator.info)
+  );
 
   if (memo == null) {
     throw new Error('memo must be a non-null Record');