in aws-lambda-function-resolvers/src/main/java/jetbrains/buildServer/runner/lambda/function/LocalLambdaFunctionInvoker.kt [17:39]
override fun invokeLambdaFunction(runDetails: List<RunDetails>): Boolean {
val functionName = lambdaFunctionResolverFactory.getLambdaFunctionResolver().resolveFunction()
logger.message("Creating request for lambda functions")
val invokeRequests = runDetails.map {
InvokeRequest()
.withFunctionName(functionName)
.withInvocationType(InvocationType.Event)
.withPayload(objectMapper.writeValueAsString(it))
}
if (isInterrupted.get()) {
return true
}
logger.message("Adding requests to event queue")
invokeRequests.forEach {
awsLambda.invoke(it)
}
return false
}