Skip to content

Commit 837ddbe

Browse files
committed
fix formatting issues.
1 parent 4302551 commit 837ddbe

3 files changed

Lines changed: 7 additions & 11 deletions

File tree

packages/common/src/converter/extstore.ts

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -115,7 +115,7 @@ const DEFAULT_PAYLOAD_SIZE_THRESHOLD = 256 * 1024;
115115
/**
116116
* Configuration for external storage. Holds the registered drivers, an
117117
* optional selector, and the size threshold above which payloads are
118-
* eligible for offloading to external storage. A selector function is
118+
* eligible for offloading to external storage. A selector function is
119119
* required when more than one driver is registered.
120120
*
121121
* @internal
@@ -125,7 +125,7 @@ export class ExternalStorage {
125125
readonly drivers: StorageDriver[];
126126
/**
127127
* Selects the destination driver for each payload, or returns `null` to keep
128-
* the payload inline.
128+
* the payload inline.
129129
*/
130130
readonly driverSelector: StorageDriverSelector;
131131
readonly payloadSizeThreshold: number;

packages/common/src/internal-non-workflow/external-storage-runner.ts

Lines changed: 2 additions & 8 deletions
Original file line numberDiff line numberDiff line change
@@ -179,18 +179,12 @@ function payloadProtoSize(payload: Payload): number {
179179
*/
180180
function makeBatchSignal(abortSignal?: AbortSignal): { batchSignal: AbortSignal; batchController: AbortController } {
181181
const batchController = new AbortController();
182-
const batchSignal = abortSignal
183-
? AbortSignal.any([batchController.signal, abortSignal])
184-
: batchController.signal;
182+
const batchSignal = abortSignal ? AbortSignal.any([batchController.signal, abortSignal]) : batchController.signal;
185183
return { batchSignal, batchController };
186184
}
187185

188186
/** Invoke a driver call, wrapping non-Temporal errors as `ExternalStorageDriverOperationFailedError`. */
189-
async function callDriver<T>(
190-
driver: StorageDriver,
191-
operation: 'store' | 'retrieve',
192-
fn: () => Promise<T>
193-
): Promise<T> {
187+
async function callDriver<T>(driver: StorageDriver, operation: 'store' | 'retrieve', fn: () => Promise<T>): Promise<T> {
194188
try {
195189
return await fn();
196190
} catch (cause) {

packages/test/src/test-extstore-runner.ts

Lines changed: 3 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -189,7 +189,9 @@ test('store/retrieve round-trip preserves order across drivers', async (t) => {
189189

190190
test('retrieve raises ValueError when the driver name is unknown', async (t) => {
191191
const writerDriver = makeFakeDriver({ name: 'writer' });
192-
const writerRunner = new ExternalStorageRunner(new ExternalStorage({ drivers: [writerDriver], payloadSizeThreshold: 0 }));
192+
const writerRunner = new ExternalStorageRunner(
193+
new ExternalStorage({ drivers: [writerDriver], payloadSizeThreshold: 0 })
194+
);
193195
const storedPayloads = await writerRunner.store([makePayload(1)]);
194196

195197
const readerDriver = makeFakeDriver({ name: 'different-name' });

0 commit comments

Comments
 (0)