How Do I Schedule AWS EMR Serverless Jobs Using AWS Scheduler?

import * as pulumi from "@pulumi/pulumi";
import * as aws from "@pulumi/aws";

// Create an EMR Serverless Application
const emrApp = new aws.emrserverless.Application("emrApp", {
    name: "my-emr-serverless-app",
    type: "SPARK", // Specify the type of application (e.g., SPARK, HIVE)
    releaseLabel: "emr-6.4.0", // EMR release version
    maximumCapacity: {
        cpu: "4 vCPU",
        memory: "16 GB",
    },
    initialCapacities: [{
        initialCapacityType: "DRIVER",
        initialCapacityConfig: {
            workerCount: 1,
            workerConfiguration: {
                cpu: "2 vCPU",
                memory: "8 GB",
            },
        },
    }],
});

// Create an IAM Role for the Scheduler to trigger the EMR application
const schedulerRole = new aws.iam.Role("schedulerRole", {
    assumeRolePolicy: aws.iam.assumeRolePolicyForPrincipal({ Service: "scheduler.amazonaws.com" }),
});

// Attach the necessary policies to the role
const schedulerRolePolicy = new aws.iam.RolePolicy("schedulerRolePolicy", {
    role: schedulerRole.id,
    policy: pulumi.output({
        Version: "2012-10-17",
        Statement: [{
            Effect: "Allow",
            Action: [
                "emr:StartJobRun",
            ],
            Resource: "*", // Adjust the resource as needed
        }],
    }),
});

// Create an AWS Scheduler Schedule
const schedule = new aws.scheduler.Schedule("emrSchedule", {
    name: "my-emr-schedule",
    scheduleExpression: "cron(0 12 * * ? *)", // Every day at 12 PM UTC
    flexibleTimeWindow: {
        mode: "OFF",
    },
    target: {
        arn: emrApp.id, // ARN of the EMR Serverless application
        roleArn: schedulerRole.arn,
        input: JSON.stringify({
            name: "my-emr-job",
            executionRoleArn: schedulerRole.arn, // Role to execute the job
            releaseLabel: "emr-6.4.0",
            jobDriver: {
                sparkSubmitJobDriver: {
                    entryPoint: "s3://my-bucket/my-script.py", // Replace with your script location
                },
            },
            configurationOverrides: {
                monitoringConfiguration: {
                    s3MonitoringConfiguration: {
                        logUri: "s3://my-bucket/logs/",
                    },
                },
            },
        }),
    },
});