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 is None.

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)