override fun execute()

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
        )
    }