in dsl/kotless/kotless-lang-local/src/main/kotlin/io/kotless/local/scheduled/ScheduledJob.kt [45:60]
override fun execute(context: JobExecutionContext) {
val handler = context.mergedJobDataMap[HANDLER_KEY] as HandlerAWS
val id = context.mergedJobDataMap[ID_KEY] as String
val apiRequest = CloudWatch(
`detail-type` = "Scheduled Event",
source = "aws.events",
resources = setOf(id)
)
handler.handleRequest(
input = JSON.string(CloudWatch.serializer(), apiRequest).byteInputStream(),
output = ByteArrayOutputStream(),
any = null
)
}