def iter_list_cluster_events(
self,
*,
config_overrides: Optional[SageMakerClientConfig] = None,
cluster_name: Optional[
"capo_sagemaker.types.cluster_name_or_arn.ClusterNameOrArn"
] = None,
instance_group_name: Optional[
"capo_sagemaker.types.cluster_instance_group_name.ClusterInstanceGroupName"
] = None,
node_id: Optional["capo_sagemaker.types.cluster_node_id.ClusterNodeId"] = None,
event_time_after: Optional["capo_sagemaker.types.timestamp.Timestamp"] = None,
event_time_before: Optional["capo_sagemaker.types.timestamp.Timestamp"] = None,
sort_by: Optional["capo_sagemaker.types.event_sort_by.EventSortBy"] = None,
sort_order: Optional["capo_sagemaker.types.sort_order.SortOrder"] = None,
resource_type: Optional[
"capo_sagemaker.types.cluster_event_resource_type.ClusterEventResourceType"
] = None,
max_results: Optional[
"capo_sagemaker.types.cluster_event_max_results.ClusterEventMaxResults"
] = None,
next_token: Optional["capo_sagemaker.types.next_token.NextToken"] = None,
) -> "Iterator[capo_sagemaker.types.cluster_event_summary.ClusterEventSummary]":
_token = next_token
while True:
_response = self.list_cluster_events(
config_overrides=config_overrides,
cluster_name=cluster_name,
instance_group_name=instance_group_name,
node_id=node_id,
event_time_after=event_time_after,
event_time_before=event_time_before,
sort_by=sort_by,
sort_order=sort_order,
resource_type=resource_type,
max_results=max_results,
next_token=_token,
)
_page = _resolve_path(_response, ("events",))
for _item in _page or []:
yield _item
_token = _resolve_path(_response, ("next_token",))
if not _token:
break