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.
- Return type
str
Static Methods
-
classmethod
from_task_input
(task_input)¶ Input for a virtualClusterId from a Task Input.
- Parameters
task_input (
TaskInput
) –- Return type
-
classmethod
from_virtual_cluster_id
(virtual_cluster_id)¶ Input for virtualClusterId from a literal string.
- Parameters
virtual_cluster_id (
str
) –- Return type