style(batch): apply stricter linting

Author: dreamorosi

packages/batch/src/BasePartialProcessor.ts

@@ -239,9 +239,7 @@ abstract class BasePartialProcessor {
   /**
    * Processes records in parallel using `Promise.all`.
    */
-  async #processRecordsInParallel(): Promise<
-    (SuccessResponse | FailureResponse)[]
-  > {
+  #processRecordsInParallel(): Promise<(SuccessResponse | FailureResponse)[]> {
     return Promise.all(
       this.records.map((record) => this.processRecord(record))
     );

packages/batch/src/BatchProcessorSync.ts

@@ -88,7 +88,7 @@ import type { BaseRecord, FailureResponse, SuccessResponse } from './types.js';
    *
    * @param _record The record to be processed
    */
-  public async processRecord(
+  public processRecord(
     _record: BaseRecord
   ): Promise<SuccessResponse | FailureResponse> {
     throw new BatchProcessingError('Not implemented. Use process() instead.');

packages/batch/tests/helpers/handlers.ts

@@ -39,7 +39,7 @@ const dynamodbRecordHandler = (record: DynamoDBRecord): object => {
   return body;
 };
 
-const asyncDynamodbRecordHandler = async (
+const asyncDynamodbRecordHandler = (
   record: DynamoDBRecord
 ): Promise<object> => {
   return Promise.resolve(dynamodbRecordHandler(record));
@@ -57,7 +57,7 @@ const handlerWithContext = (record: SQSRecord, context: Context): string => {
   return record.body;
 };
 
-const asyncHandlerWithContext = async (
+const asyncHandlerWithContext = (
   record: SQSRecord,
   context: Context
 ): Promise<string> => {

packages/batch/tests/unit/BasePartialProcessor.test.ts

@@ -25,7 +25,7 @@ describe('Class: BasePartialBatchProcessor', () => {
       super(EventType.SQS);
     }
 
-    public async processRecord(
+    public processRecord(
       _record: BaseRecord
     ): Promise<SuccessResponse | FailureResponse> {
       throw new Error('Not implemented');

packages/batch/tests/unit/SqsFifoPartialProcessor.test.ts

@@ -186,7 +186,7 @@ describe('SQS FIFO Processors', () => {
     });
   }
 
-  it('continues processing and moves to the next group when `skipGroupOnError` is true', async () => {
+  it('continues processing and moves to the next group when `skipGroupOnError` is true', () => {
     // Prepare
     const firstRecord = sqsRecordFactory('fail', '1');
     const secondRecord = sqsRecordFactory('success', '2');

packages/batch/tests/unit/processPartialResponse.test.ts

@@ -36,7 +36,7 @@ describe('Function: processPartialResponse()', () => {
     context,
   };
 
-  const handlerWithSqsEvent = async (
+  const handlerWithSqsEvent = (
     event: SQSEvent,
     options: BatchProcessingOptions
   ) => {
@@ -51,7 +51,7 @@ describe('Function: processPartialResponse()', () => {
     return handler(event, context);
   };
 
-  const handlerWithKinesisEvent = async (
+  const handlerWithKinesisEvent = (
     event: KinesisStreamEvent,
     options: BatchProcessingOptions
   ) => {
@@ -71,7 +71,7 @@ describe('Function: processPartialResponse()', () => {
     return handler(event, context);
   };
 
-  const handlerWithDynamoDBEvent = async (
+  const handlerWithDynamoDBEvent = (
     event: DynamoDBStreamEvent,
     options: BatchProcessingOptions
   ) => {