Skip to content

Commit 51e57d8

Browse files
committed
Fixed camelCasing.
1 parent 5cb8ab6 commit 51e57d8

File tree

2 files changed

+7
-7
lines changed

2 files changed

+7
-7
lines changed

src/workers/create-worker.ts

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -13,7 +13,7 @@ async function createWorker<ConnectorState>(
1313
event: workerData.event,
1414
options: workerData.options,
1515
}));
16-
const unverified_logger = createUserLogger(new Logger({
16+
const unverifiedLogger = createUserLogger(new Logger({
1717
event: workerData.event,
1818
options: workerData.options,
1919
}));
@@ -24,7 +24,7 @@ async function createWorker<ConnectorState>(
2424
} as WorkerOptions);
2525

2626
worker.on(WorkerEvent.WorkerError, (error) => {
27-
unverified_logger.error('Worker error', error);
27+
unverifiedLogger.error('Worker error', error);
2828
reject();
2929
});
3030
worker.on(WorkerEvent.WorkerOnline, () => {

src/workers/spawn.ts

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -96,7 +96,7 @@ export async function spawn<ConnectorState>({
9696
options,
9797
}: SpawnFactoryInterface<ConnectorState>): Promise<void> {
9898
const logger = getInternalLogger(new Logger({ event, options }));
99-
const unverified_logger = createUserLogger(new Logger({ event, options }));
99+
const unverifiedLogger = createUserLogger(new Logger({ event, options }));
100100
const script = getWorkerPath({
101101
event,
102102
connectorWorkerPath: workerPath,
@@ -136,7 +136,7 @@ export async function spawn<ConnectorState>({
136136
});
137137
});
138138
} catch (error) {
139-
unverified_logger.error('Worker error while processing task', error);
139+
unverifiedLogger.error('Worker error while processing task', error);
140140
}
141141
} else {
142142
console.error(
@@ -171,14 +171,14 @@ export class Spawn {
171171
private hardTimeoutTimer: ReturnType<typeof setTimeout> | undefined;
172172
private memoryMonitoringInterval: ReturnType<typeof setInterval> | undefined;
173173
private logger: Logger;
174-
private unverified_logger: Logger;
174+
private unverifiedLogger: Logger;
175175
private resolve: (value: void | PromiseLike<void>) => void;
176176

177177
constructor({ event, worker, options, resolve }: SpawnInterface) {
178178
this.alreadyEmitted = false;
179179
this.event = event;
180180
this.logger = getInternalLogger(new Logger({ event, options }));
181-
this.unverified_logger = createUserLogger(new Logger({ event, options }));
181+
this.unverifiedLogger = createUserLogger(new Logger({ event, options }));
182182
this.lambdaTimeout = options?.timeout
183183
? Math.min(options.timeout, this.defaultLambdaTimeout)
184184
: this.defaultLambdaTimeout;
@@ -225,7 +225,7 @@ export class Spawn {
225225
if (message?.subject === WorkerMessageSubject.WorkerMessageLog) {
226226
const args = message.payload?.args;
227227
const level = message.payload?.level as LogLevel;
228-
this.unverified_logger.logFn(args, level);
228+
this.unverifiedLogger.logFn(args, level);
229229
}
230230

231231
// If worker sends a message that it has emitted an event, then set alreadyEmitted to true.

0 commit comments

Comments
 (0)