awswrangler.emr.submit_steps¶
- awswrangler.emr.submit_steps(cluster_id: str, steps: list[dict[str, Any]], boto3_session: Session | None = None) list[str] ¶
Submit a list of steps.
- Parameters:
cluster_id (
str
) – Cluster ID.steps (
list
[dict
[str
,Any
]]) – Steps definitions (Obs: Use EMR.build_step() to build it).boto3_session (
Session
|None
) – The default boto3 session will be used if boto3_session isNone
.
- Return type:
list
[str
]- Returns:
List of step IDs.
Examples
>>> import awswrangler as wr >>> for cmd in ['echo "Hello"', "ls -la"]: ... steps.append(wr.emr.build_step(name=cmd, command=cmd)) >>> wr.emr.submit_steps(cluster_id="cluster-id", steps=steps)