VirtualClusterInput

class aws_cdk.aws_stepfunctions_tasks.VirtualClusterInput(*args: Any, **kwargs)

Bases: object

Class that returns a virtual cluster’s id depending on input type.

ExampleMetadata:: infused

Example:

tasks.EmrContainersStartJobRun(self, "EMR Containers Start Job Run",
    virtual_cluster=tasks.VirtualClusterInput.from_virtual_cluster_id("de92jdei2910fwedz"),
    release_label=tasks.ReleaseLabel.EMR_6_2_0,
    job_name="EMR-Containers-Job",
    job_driver=tasks.JobDriver(
        spark_submit_job_driver=tasks.SparkSubmitJobDriver(
            entry_point=sfn.TaskInput.from_text("local:///usr/lib/spark/examples/src/main/python/pi.py")
        )
    ),
    application_config=[tasks.ApplicationConfiguration(
        classification=tasks.Classification.SPARK_DEFAULTS,
        properties={
            "spark.executor.instances": "1",
            "spark.executor.memory": "512M"
        }
    )]
)

Attributes

id: The VirtualCluster Id.

Static Methods

classmethod from_task_input(task_input)

Input for a virtualClusterId from a Task Input.

Parameters:: task_input (TaskInput)
Return type:: VirtualClusterInput

classmethod from_virtual_cluster_id(virtual_cluster_id)

Input for virtualClusterId from a literal string.

Parameters:: virtual_cluster_id (str)
Return type:: VirtualClusterInput