13
13
"""The step definitions for workflow."""
14
14
from __future__ import absolute_import
15
15
16
- from typing import List , Union , Optional
16
+ from typing import Any , Dict , List , Union , Optional
17
17
18
18
from sagemaker .workflow .entities import (
19
19
RequestType ,
@@ -153,7 +153,7 @@ def __init__(
153
153
step_config : EMRStepConfig ,
154
154
depends_on : Optional [List [Union [str , Step , StepCollection ]]] = None ,
155
155
cache_config : CacheConfig = None ,
156
- cluster_config : RequestType = None ,
156
+ cluster_config : Dict [ str , Any ] = None ,
157
157
):
158
158
"""Constructs an EMRStep.
159
159
@@ -167,7 +167,7 @@ def __init__(
167
167
names or `Step` instances or `StepCollection` instances that this `EMRStep`
168
168
depends on.
169
169
cache_config(CacheConfig): A `sagemaker.workflow.steps.CacheConfig` instance.
170
- cluster_config(Union[ Dict[str, Any], List[Dict[str, Any]] ]): The recipe of the
170
+ cluster_config(Dict[str, Any]): The recipe of the
171
171
EMR cluster, passed as a dictionary. The elements are defined in the request syntax
172
172
for RunJobFlow. However, the following elements are not recognized as part of the
173
173
cluster configuration and you should not include them in the dictionary:
0 commit comments