ok

Author: reakaleek

src/infra/docs-lambda-index-publisher/Program.cs

@@ -23,7 +23,11 @@
 
 return;
 
-static async Task<SQSBatchResponse> Handler(SQSEvent ev, ILambdaContext context)
+// This function should return SQSBatchResponse but for some reason
+// it's not working as expected.
+// The partial batch response might not be serialized correctly.
+// However, serializing the response to JSON and returning it as string works.
+static async Task<string> Handler(SQSEvent ev, ILambdaContext context)
 {
 	var s3Client = new AmazonS3Client();
 	var batchItemFailures = new List<SQSBatchResponse.BatchItemFailure>();
@@ -83,7 +87,7 @@ static async Task<SQSBatchResponse> Handler(SQSEvent ev, ILambdaContext context)
 			context.Logger.LogInformation($"Failed to process {batchItemFailures.Count}  messages. Returning them to the queue.");
 			context.Logger.LogInformation(jsonString);
 		}
-		return response;
+		return jsonString;
 	}
 	catch (Exception ex)
 	{
@@ -101,7 +105,7 @@ static async Task<SQSBatchResponse> Handler(SQSEvent ev, ILambdaContext context)
 		}).ToList());
 		var jsonString = JsonSerializer.Serialize(response, LinkIndexUpdaterSerializerContext.Default.SQSBatchResponse);
 		context.Logger.LogInformation(jsonString);
-		return response;
+		return jsonString;
 	}
 }