AWS SDK for C++

AWS SDK for C++ Version 1.11.778
Loading...
Searching...
No Matches
SageMakerWaiter.h
1
6#pragma once
7#include <aws/core/utils/Waiter.h>
8#include <aws/core/utils/memory/AWSMemory.h>
9#include <aws/sagemaker/SageMakerClient.h>
10#include <aws/sagemaker/model/DescribeEndpointRequest.h>
11#include <aws/sagemaker/model/DescribeEndpointResult.h>
12#include <aws/sagemaker/model/DescribeImageRequest.h>
13#include <aws/sagemaker/model/DescribeImageResult.h>
14#include <aws/sagemaker/model/DescribeImageVersionRequest.h>
15#include <aws/sagemaker/model/DescribeImageVersionResult.h>
16#include <aws/sagemaker/model/DescribeNotebookInstanceRequest.h>
17#include <aws/sagemaker/model/DescribeNotebookInstanceResult.h>
18#include <aws/sagemaker/model/DescribeProcessingJobRequest.h>
19#include <aws/sagemaker/model/DescribeProcessingJobResult.h>
20#include <aws/sagemaker/model/DescribeTrainingJobRequest.h>
21#include <aws/sagemaker/model/DescribeTrainingJobResult.h>
22#include <aws/sagemaker/model/DescribeTransformJobRequest.h>
23#include <aws/sagemaker/model/DescribeTransformJobResult.h>
24#include <aws/sagemaker/model/EndpointStatus.h>
25#include <aws/sagemaker/model/ImageStatus.h>
26#include <aws/sagemaker/model/ImageVersionStatus.h>
27#include <aws/sagemaker/model/NotebookInstanceStatus.h>
28#include <aws/sagemaker/model/ProcessingJobStatus.h>
29#include <aws/sagemaker/model/TrainingJobStatus.h>
30#include <aws/sagemaker/model/TransformJobStatus.h>
31
32#include <algorithm>
33
34namespace Aws {
35namespace SageMaker {
36
37template <typename DerivedClient = SageMakerClient>
38class SageMakerWaiter {
39 public:
40 Aws::Utils::WaiterOutcome<Model::DescribeEndpointOutcome> WaitUntilEndpointDeleted(const Model::DescribeEndpointRequest& request) {
41 using OutcomeT = Model::DescribeEndpointOutcome;
42 using RequestT = Model::DescribeEndpointRequest;
43 Aws::Vector<Aws::UniquePtr<Aws::Utils::Acceptor<OutcomeT>>> acceptors;
44 acceptors.emplace_back(Aws::MakeUnique<Aws::Utils::ErrorAcceptor<OutcomeT>>("EndpointDeletedWaiter", Aws::Utils::WaiterState::SUCCESS,
45 Aws::String("ValidationException")));
46 acceptors.emplace_back(Aws::MakeUnique<Aws::Utils::PathAcceptor<OutcomeT>>(
47 "EndpointDeletedWaiter", Aws::Utils::WaiterState::FAILURE, Aws::String("Failed"),
48 [](const Model::DescribeEndpointOutcome& outcome, const Aws::Utils::ExpectedValue& expected) -> bool {
49 if (!outcome.IsSuccess()) return false;
50 const auto& result = outcome.GetResult();
51 return Model::EndpointStatusMapper::GetNameForEndpointStatus(result.GetEndpointStatus()) == expected.get<Aws::String>();
52 }));
53
54 auto operation = [this](const RequestT& req) { return static_cast<DerivedClient*>(this)->DescribeEndpoint(req); };
55 Aws::Utils::Waiter<RequestT, OutcomeT> waiter(30, 60, std::move(acceptors), operation, "WaitUntilEndpointDeleted");
56 return waiter.Wait(request);
57 }
58
59 Aws::Utils::WaiterOutcome<Model::DescribeEndpointOutcome> WaitUntilEndpointInService(const Model::DescribeEndpointRequest& request) {
60 using OutcomeT = Model::DescribeEndpointOutcome;
61 using RequestT = Model::DescribeEndpointRequest;
62 Aws::Vector<Aws::UniquePtr<Aws::Utils::Acceptor<OutcomeT>>> acceptors;
63 acceptors.emplace_back(Aws::MakeUnique<Aws::Utils::PathAcceptor<OutcomeT>>(
64 "EndpointInServiceWaiter", Aws::Utils::WaiterState::SUCCESS, Aws::String("InService"),
65 [](const Model::DescribeEndpointOutcome& outcome, const Aws::Utils::ExpectedValue& expected) -> bool {
66 if (!outcome.IsSuccess()) return false;
67 const auto& result = outcome.GetResult();
68 return Model::EndpointStatusMapper::GetNameForEndpointStatus(result.GetEndpointStatus()) == expected.get<Aws::String>();
69 }));
70 acceptors.emplace_back(Aws::MakeUnique<Aws::Utils::PathAcceptor<OutcomeT>>(
71 "EndpointInServiceWaiter", Aws::Utils::WaiterState::FAILURE, Aws::String("Failed"),
72 [](const Model::DescribeEndpointOutcome& outcome, const Aws::Utils::ExpectedValue& expected) -> bool {
73 if (!outcome.IsSuccess()) return false;
74 const auto& result = outcome.GetResult();
75 return Model::EndpointStatusMapper::GetNameForEndpointStatus(result.GetEndpointStatus()) == expected.get<Aws::String>();
76 }));
77 acceptors.emplace_back(Aws::MakeUnique<Aws::Utils::ErrorAcceptor<OutcomeT>>("EndpointInServiceWaiter", Aws::Utils::WaiterState::FAILURE,
78 Aws::String("ValidationException")));
79
80 auto operation = [this](const RequestT& req) { return static_cast<DerivedClient*>(this)->DescribeEndpoint(req); };
81 Aws::Utils::Waiter<RequestT, OutcomeT> waiter(30, 120, std::move(acceptors), operation, "WaitUntilEndpointInService");
82 return waiter.Wait(request);
83 }
84
85 Aws::Utils::WaiterOutcome<Model::DescribeImageOutcome> WaitUntilImageCreated(const Model::DescribeImageRequest& request) {
86 using OutcomeT = Model::DescribeImageOutcome;
87 using RequestT = Model::DescribeImageRequest;
88 Aws::Vector<Aws::UniquePtr<Aws::Utils::Acceptor<OutcomeT>>> acceptors;
89 acceptors.emplace_back(Aws::MakeUnique<Aws::Utils::PathAcceptor<OutcomeT>>(
90 "ImageCreatedWaiter", Aws::Utils::WaiterState::SUCCESS, Aws::String("CREATED"),
91 [](const Model::DescribeImageOutcome& outcome, const Aws::Utils::ExpectedValue& expected) -> bool {
92 if (!outcome.IsSuccess()) return false;
93 const auto& result = outcome.GetResult();
94 return Model::ImageStatusMapper::GetNameForImageStatus(result.GetImageStatus()) == expected.get<Aws::String>();
95 }));
96 acceptors.emplace_back(Aws::MakeUnique<Aws::Utils::PathAcceptor<OutcomeT>>(
97 "ImageCreatedWaiter", Aws::Utils::WaiterState::FAILURE, Aws::String("CREATE_FAILED"),
98 [](const Model::DescribeImageOutcome& outcome, const Aws::Utils::ExpectedValue& expected) -> bool {
99 if (!outcome.IsSuccess()) return false;
100 const auto& result = outcome.GetResult();
101 return Model::ImageStatusMapper::GetNameForImageStatus(result.GetImageStatus()) == expected.get<Aws::String>();
102 }));
103 acceptors.emplace_back(Aws::MakeUnique<Aws::Utils::ErrorAcceptor<OutcomeT>>("ImageCreatedWaiter", Aws::Utils::WaiterState::FAILURE,
104 Aws::String("ValidationException")));
105
106 auto operation = [this](const RequestT& req) { return static_cast<DerivedClient*>(this)->DescribeImage(req); };
107 Aws::Utils::Waiter<RequestT, OutcomeT> waiter(60, 60, std::move(acceptors), operation, "WaitUntilImageCreated");
108 return waiter.Wait(request);
109 }
110
111 Aws::Utils::WaiterOutcome<Model::DescribeImageOutcome> WaitUntilImageDeleted(const Model::DescribeImageRequest& request) {
112 using OutcomeT = Model::DescribeImageOutcome;
113 using RequestT = Model::DescribeImageRequest;
114 Aws::Vector<Aws::UniquePtr<Aws::Utils::Acceptor<OutcomeT>>> acceptors;
115 acceptors.emplace_back(Aws::MakeUnique<Aws::Utils::ErrorAcceptor<OutcomeT>>("ImageDeletedWaiter", Aws::Utils::WaiterState::SUCCESS,
116 Aws::String("ResourceNotFoundException")));
117 acceptors.emplace_back(Aws::MakeUnique<Aws::Utils::PathAcceptor<OutcomeT>>(
118 "ImageDeletedWaiter", Aws::Utils::WaiterState::FAILURE, Aws::String("DELETE_FAILED"),
119 [](const Model::DescribeImageOutcome& outcome, const Aws::Utils::ExpectedValue& expected) -> bool {
120 if (!outcome.IsSuccess()) return false;
121 const auto& result = outcome.GetResult();
122 return Model::ImageStatusMapper::GetNameForImageStatus(result.GetImageStatus()) == expected.get<Aws::String>();
123 }));
124 acceptors.emplace_back(Aws::MakeUnique<Aws::Utils::ErrorAcceptor<OutcomeT>>("ImageDeletedWaiter", Aws::Utils::WaiterState::FAILURE,
125 Aws::String("ValidationException")));
126
127 auto operation = [this](const RequestT& req) { return static_cast<DerivedClient*>(this)->DescribeImage(req); };
128 Aws::Utils::Waiter<RequestT, OutcomeT> waiter(60, 60, std::move(acceptors), operation, "WaitUntilImageDeleted");
129 return waiter.Wait(request);
130 }
131
132 Aws::Utils::WaiterOutcome<Model::DescribeImageOutcome> WaitUntilImageUpdated(const Model::DescribeImageRequest& request) {
133 using OutcomeT = Model::DescribeImageOutcome;
134 using RequestT = Model::DescribeImageRequest;
135 Aws::Vector<Aws::UniquePtr<Aws::Utils::Acceptor<OutcomeT>>> acceptors;
136 acceptors.emplace_back(Aws::MakeUnique<Aws::Utils::PathAcceptor<OutcomeT>>(
137 "ImageUpdatedWaiter", Aws::Utils::WaiterState::SUCCESS, Aws::String("CREATED"),
138 [](const Model::DescribeImageOutcome& outcome, const Aws::Utils::ExpectedValue& expected) -> bool {
139 if (!outcome.IsSuccess()) return false;
140 const auto& result = outcome.GetResult();
141 return Model::ImageStatusMapper::GetNameForImageStatus(result.GetImageStatus()) == expected.get<Aws::String>();
142 }));
143 acceptors.emplace_back(Aws::MakeUnique<Aws::Utils::PathAcceptor<OutcomeT>>(
144 "ImageUpdatedWaiter", Aws::Utils::WaiterState::FAILURE, Aws::String("UPDATE_FAILED"),
145 [](const Model::DescribeImageOutcome& outcome, const Aws::Utils::ExpectedValue& expected) -> bool {
146 if (!outcome.IsSuccess()) return false;
147 const auto& result = outcome.GetResult();
148 return Model::ImageStatusMapper::GetNameForImageStatus(result.GetImageStatus()) == expected.get<Aws::String>();
149 }));
150 acceptors.emplace_back(Aws::MakeUnique<Aws::Utils::ErrorAcceptor<OutcomeT>>("ImageUpdatedWaiter", Aws::Utils::WaiterState::FAILURE,
151 Aws::String("ValidationException")));
152
153 auto operation = [this](const RequestT& req) { return static_cast<DerivedClient*>(this)->DescribeImage(req); };
154 Aws::Utils::Waiter<RequestT, OutcomeT> waiter(60, 60, std::move(acceptors), operation, "WaitUntilImageUpdated");
155 return waiter.Wait(request);
156 }
157
158 Aws::Utils::WaiterOutcome<Model::DescribeImageVersionOutcome> WaitUntilImageVersionCreated(
159 const Model::DescribeImageVersionRequest& request) {
160 using OutcomeT = Model::DescribeImageVersionOutcome;
161 using RequestT = Model::DescribeImageVersionRequest;
162 Aws::Vector<Aws::UniquePtr<Aws::Utils::Acceptor<OutcomeT>>> acceptors;
163 acceptors.emplace_back(Aws::MakeUnique<Aws::Utils::PathAcceptor<OutcomeT>>(
164 "ImageVersionCreatedWaiter", Aws::Utils::WaiterState::SUCCESS, Aws::String("CREATED"),
165 [](const Model::DescribeImageVersionOutcome& outcome, const Aws::Utils::ExpectedValue& expected) -> bool {
166 if (!outcome.IsSuccess()) return false;
167 const auto& result = outcome.GetResult();
168 return Model::ImageVersionStatusMapper::GetNameForImageVersionStatus(result.GetImageVersionStatus()) ==
169 expected.get<Aws::String>();
170 }));
171 acceptors.emplace_back(Aws::MakeUnique<Aws::Utils::PathAcceptor<OutcomeT>>(
172 "ImageVersionCreatedWaiter", Aws::Utils::WaiterState::FAILURE, Aws::String("CREATE_FAILED"),
173 [](const Model::DescribeImageVersionOutcome& outcome, const Aws::Utils::ExpectedValue& expected) -> bool {
174 if (!outcome.IsSuccess()) return false;
175 const auto& result = outcome.GetResult();
176 return Model::ImageVersionStatusMapper::GetNameForImageVersionStatus(result.GetImageVersionStatus()) ==
177 expected.get<Aws::String>();
178 }));
179 acceptors.emplace_back(Aws::MakeUnique<Aws::Utils::ErrorAcceptor<OutcomeT>>(
180 "ImageVersionCreatedWaiter", Aws::Utils::WaiterState::FAILURE, Aws::String("ValidationException")));
181
182 auto operation = [this](const RequestT& req) { return static_cast<DerivedClient*>(this)->DescribeImageVersion(req); };
183 Aws::Utils::Waiter<RequestT, OutcomeT> waiter(60, 60, std::move(acceptors), operation, "WaitUntilImageVersionCreated");
184 return waiter.Wait(request);
185 }
186
187 Aws::Utils::WaiterOutcome<Model::DescribeImageVersionOutcome> WaitUntilImageVersionDeleted(
188 const Model::DescribeImageVersionRequest& request) {
189 using OutcomeT = Model::DescribeImageVersionOutcome;
190 using RequestT = Model::DescribeImageVersionRequest;
191 Aws::Vector<Aws::UniquePtr<Aws::Utils::Acceptor<OutcomeT>>> acceptors;
192 acceptors.emplace_back(Aws::MakeUnique<Aws::Utils::ErrorAcceptor<OutcomeT>>(
193 "ImageVersionDeletedWaiter", Aws::Utils::WaiterState::SUCCESS, Aws::String("ResourceNotFoundException")));
194 acceptors.emplace_back(Aws::MakeUnique<Aws::Utils::PathAcceptor<OutcomeT>>(
195 "ImageVersionDeletedWaiter", Aws::Utils::WaiterState::FAILURE, Aws::String("DELETE_FAILED"),
196 [](const Model::DescribeImageVersionOutcome& outcome, const Aws::Utils::ExpectedValue& expected) -> bool {
197 if (!outcome.IsSuccess()) return false;
198 const auto& result = outcome.GetResult();
199 return Model::ImageVersionStatusMapper::GetNameForImageVersionStatus(result.GetImageVersionStatus()) ==
200 expected.get<Aws::String>();
201 }));
202 acceptors.emplace_back(Aws::MakeUnique<Aws::Utils::ErrorAcceptor<OutcomeT>>(
203 "ImageVersionDeletedWaiter", Aws::Utils::WaiterState::FAILURE, Aws::String("ValidationException")));
204
205 auto operation = [this](const RequestT& req) { return static_cast<DerivedClient*>(this)->DescribeImageVersion(req); };
206 Aws::Utils::Waiter<RequestT, OutcomeT> waiter(60, 60, std::move(acceptors), operation, "WaitUntilImageVersionDeleted");
207 return waiter.Wait(request);
208 }
209
210 Aws::Utils::WaiterOutcome<Model::DescribeNotebookInstanceOutcome> WaitUntilNotebookInstanceDeleted(
211 const Model::DescribeNotebookInstanceRequest& request) {
212 using OutcomeT = Model::DescribeNotebookInstanceOutcome;
213 using RequestT = Model::DescribeNotebookInstanceRequest;
214 Aws::Vector<Aws::UniquePtr<Aws::Utils::Acceptor<OutcomeT>>> acceptors;
215 acceptors.emplace_back(Aws::MakeUnique<Aws::Utils::ErrorAcceptor<OutcomeT>>(
216 "NotebookInstanceDeletedWaiter", Aws::Utils::WaiterState::SUCCESS, Aws::String("ValidationException")));
217 acceptors.emplace_back(Aws::MakeUnique<Aws::Utils::PathAcceptor<OutcomeT>>(
218 "NotebookInstanceDeletedWaiter", Aws::Utils::WaiterState::FAILURE, Aws::String("Failed"),
219 [](const Model::DescribeNotebookInstanceOutcome& outcome, const Aws::Utils::ExpectedValue& expected) -> bool {
220 if (!outcome.IsSuccess()) return false;
221 const auto& result = outcome.GetResult();
222 return Model::NotebookInstanceStatusMapper::GetNameForNotebookInstanceStatus(result.GetNotebookInstanceStatus()) ==
223 expected.get<Aws::String>();
224 }));
225
226 auto operation = [this](const RequestT& req) { return static_cast<DerivedClient*>(this)->DescribeNotebookInstance(req); };
227 Aws::Utils::Waiter<RequestT, OutcomeT> waiter(30, 60, std::move(acceptors), operation, "WaitUntilNotebookInstanceDeleted");
228 return waiter.Wait(request);
229 }
230
231 Aws::Utils::WaiterOutcome<Model::DescribeNotebookInstanceOutcome> WaitUntilNotebookInstanceInService(
232 const Model::DescribeNotebookInstanceRequest& request) {
233 using OutcomeT = Model::DescribeNotebookInstanceOutcome;
234 using RequestT = Model::DescribeNotebookInstanceRequest;
235 Aws::Vector<Aws::UniquePtr<Aws::Utils::Acceptor<OutcomeT>>> acceptors;
236 acceptors.emplace_back(Aws::MakeUnique<Aws::Utils::PathAcceptor<OutcomeT>>(
237 "NotebookInstanceInServiceWaiter", Aws::Utils::WaiterState::SUCCESS, Aws::String("InService"),
238 [](const Model::DescribeNotebookInstanceOutcome& outcome, const Aws::Utils::ExpectedValue& expected) -> bool {
239 if (!outcome.IsSuccess()) return false;
240 const auto& result = outcome.GetResult();
241 return Model::NotebookInstanceStatusMapper::GetNameForNotebookInstanceStatus(result.GetNotebookInstanceStatus()) ==
242 expected.get<Aws::String>();
243 }));
244 acceptors.emplace_back(Aws::MakeUnique<Aws::Utils::PathAcceptor<OutcomeT>>(
245 "NotebookInstanceInServiceWaiter", Aws::Utils::WaiterState::FAILURE, Aws::String("Failed"),
246 [](const Model::DescribeNotebookInstanceOutcome& outcome, const Aws::Utils::ExpectedValue& expected) -> bool {
247 if (!outcome.IsSuccess()) return false;
248 const auto& result = outcome.GetResult();
249 return Model::NotebookInstanceStatusMapper::GetNameForNotebookInstanceStatus(result.GetNotebookInstanceStatus()) ==
250 expected.get<Aws::String>();
251 }));
252
253 auto operation = [this](const RequestT& req) { return static_cast<DerivedClient*>(this)->DescribeNotebookInstance(req); };
254 Aws::Utils::Waiter<RequestT, OutcomeT> waiter(30, 60, std::move(acceptors), operation, "WaitUntilNotebookInstanceInService");
255 return waiter.Wait(request);
256 }
257
258 Aws::Utils::WaiterOutcome<Model::DescribeNotebookInstanceOutcome> WaitUntilNotebookInstanceStopped(
259 const Model::DescribeNotebookInstanceRequest& request) {
260 using OutcomeT = Model::DescribeNotebookInstanceOutcome;
261 using RequestT = Model::DescribeNotebookInstanceRequest;
262 Aws::Vector<Aws::UniquePtr<Aws::Utils::Acceptor<OutcomeT>>> acceptors;
263 acceptors.emplace_back(Aws::MakeUnique<Aws::Utils::PathAcceptor<OutcomeT>>(
264 "NotebookInstanceStoppedWaiter", Aws::Utils::WaiterState::SUCCESS, Aws::String("Stopped"),
265 [](const Model::DescribeNotebookInstanceOutcome& outcome, const Aws::Utils::ExpectedValue& expected) -> bool {
266 if (!outcome.IsSuccess()) return false;
267 const auto& result = outcome.GetResult();
268 return Model::NotebookInstanceStatusMapper::GetNameForNotebookInstanceStatus(result.GetNotebookInstanceStatus()) ==
269 expected.get<Aws::String>();
270 }));
271 acceptors.emplace_back(Aws::MakeUnique<Aws::Utils::PathAcceptor<OutcomeT>>(
272 "NotebookInstanceStoppedWaiter", Aws::Utils::WaiterState::FAILURE, Aws::String("Failed"),
273 [](const Model::DescribeNotebookInstanceOutcome& outcome, const Aws::Utils::ExpectedValue& expected) -> bool {
274 if (!outcome.IsSuccess()) return false;
275 const auto& result = outcome.GetResult();
276 return Model::NotebookInstanceStatusMapper::GetNameForNotebookInstanceStatus(result.GetNotebookInstanceStatus()) ==
277 expected.get<Aws::String>();
278 }));
279
280 auto operation = [this](const RequestT& req) { return static_cast<DerivedClient*>(this)->DescribeNotebookInstance(req); };
281 Aws::Utils::Waiter<RequestT, OutcomeT> waiter(30, 60, std::move(acceptors), operation, "WaitUntilNotebookInstanceStopped");
282 return waiter.Wait(request);
283 }
284
285 Aws::Utils::WaiterOutcome<Model::DescribeProcessingJobOutcome> WaitUntilProcessingJobCompletedOrStopped(
286 const Model::DescribeProcessingJobRequest& request) {
287 using OutcomeT = Model::DescribeProcessingJobOutcome;
288 using RequestT = Model::DescribeProcessingJobRequest;
289 Aws::Vector<Aws::UniquePtr<Aws::Utils::Acceptor<OutcomeT>>> acceptors;
290 acceptors.emplace_back(Aws::MakeUnique<Aws::Utils::PathAcceptor<OutcomeT>>(
291 "ProcessingJobCompletedOrStoppedWaiter", Aws::Utils::WaiterState::SUCCESS, Aws::String("Completed"),
292 [](const Model::DescribeProcessingJobOutcome& outcome, const Aws::Utils::ExpectedValue& expected) -> bool {
293 if (!outcome.IsSuccess()) return false;
294 const auto& result = outcome.GetResult();
295 return Model::ProcessingJobStatusMapper::GetNameForProcessingJobStatus(result.GetProcessingJobStatus()) ==
296 expected.get<Aws::String>();
297 }));
298 acceptors.emplace_back(Aws::MakeUnique<Aws::Utils::PathAcceptor<OutcomeT>>(
299 "ProcessingJobCompletedOrStoppedWaiter", Aws::Utils::WaiterState::SUCCESS, Aws::String("Stopped"),
300 [](const Model::DescribeProcessingJobOutcome& outcome, const Aws::Utils::ExpectedValue& expected) -> bool {
301 if (!outcome.IsSuccess()) return false;
302 const auto& result = outcome.GetResult();
303 return Model::ProcessingJobStatusMapper::GetNameForProcessingJobStatus(result.GetProcessingJobStatus()) ==
304 expected.get<Aws::String>();
305 }));
306 acceptors.emplace_back(Aws::MakeUnique<Aws::Utils::PathAcceptor<OutcomeT>>(
307 "ProcessingJobCompletedOrStoppedWaiter", Aws::Utils::WaiterState::FAILURE, Aws::String("Failed"),
308 [](const Model::DescribeProcessingJobOutcome& outcome, const Aws::Utils::ExpectedValue& expected) -> bool {
309 if (!outcome.IsSuccess()) return false;
310 const auto& result = outcome.GetResult();
311 return Model::ProcessingJobStatusMapper::GetNameForProcessingJobStatus(result.GetProcessingJobStatus()) ==
312 expected.get<Aws::String>();
313 }));
314 acceptors.emplace_back(Aws::MakeUnique<Aws::Utils::ErrorAcceptor<OutcomeT>>(
315 "ProcessingJobCompletedOrStoppedWaiter", Aws::Utils::WaiterState::FAILURE, Aws::String("ValidationException")));
316
317 auto operation = [this](const RequestT& req) { return static_cast<DerivedClient*>(this)->DescribeProcessingJob(req); };
318 Aws::Utils::Waiter<RequestT, OutcomeT> waiter(60, 60, std::move(acceptors), operation, "WaitUntilProcessingJobCompletedOrStopped");
319 return waiter.Wait(request);
320 }
321
322 Aws::Utils::WaiterOutcome<Model::DescribeTrainingJobOutcome> WaitUntilTrainingJobCompletedOrStopped(
323 const Model::DescribeTrainingJobRequest& request) {
324 using OutcomeT = Model::DescribeTrainingJobOutcome;
325 using RequestT = Model::DescribeTrainingJobRequest;
326 Aws::Vector<Aws::UniquePtr<Aws::Utils::Acceptor<OutcomeT>>> acceptors;
327 acceptors.emplace_back(Aws::MakeUnique<Aws::Utils::PathAcceptor<OutcomeT>>(
328 "TrainingJobCompletedOrStoppedWaiter", Aws::Utils::WaiterState::SUCCESS, Aws::String("Completed"),
329 [](const Model::DescribeTrainingJobOutcome& outcome, const Aws::Utils::ExpectedValue& expected) -> bool {
330 if (!outcome.IsSuccess()) return false;
331 const auto& result = outcome.GetResult();
332 return Model::TrainingJobStatusMapper::GetNameForTrainingJobStatus(result.GetTrainingJobStatus()) == expected.get<Aws::String>();
333 }));
334 acceptors.emplace_back(Aws::MakeUnique<Aws::Utils::PathAcceptor<OutcomeT>>(
335 "TrainingJobCompletedOrStoppedWaiter", Aws::Utils::WaiterState::SUCCESS, Aws::String("Stopped"),
336 [](const Model::DescribeTrainingJobOutcome& outcome, const Aws::Utils::ExpectedValue& expected) -> bool {
337 if (!outcome.IsSuccess()) return false;
338 const auto& result = outcome.GetResult();
339 return Model::TrainingJobStatusMapper::GetNameForTrainingJobStatus(result.GetTrainingJobStatus()) == expected.get<Aws::String>();
340 }));
341 acceptors.emplace_back(Aws::MakeUnique<Aws::Utils::PathAcceptor<OutcomeT>>(
342 "TrainingJobCompletedOrStoppedWaiter", Aws::Utils::WaiterState::FAILURE, Aws::String("Failed"),
343 [](const Model::DescribeTrainingJobOutcome& outcome, const Aws::Utils::ExpectedValue& expected) -> bool {
344 if (!outcome.IsSuccess()) return false;
345 const auto& result = outcome.GetResult();
346 return Model::TrainingJobStatusMapper::GetNameForTrainingJobStatus(result.GetTrainingJobStatus()) == expected.get<Aws::String>();
347 }));
348 acceptors.emplace_back(Aws::MakeUnique<Aws::Utils::ErrorAcceptor<OutcomeT>>(
349 "TrainingJobCompletedOrStoppedWaiter", Aws::Utils::WaiterState::FAILURE, Aws::String("ValidationException")));
350
351 auto operation = [this](const RequestT& req) { return static_cast<DerivedClient*>(this)->DescribeTrainingJob(req); };
352 Aws::Utils::Waiter<RequestT, OutcomeT> waiter(120, 180, std::move(acceptors), operation, "WaitUntilTrainingJobCompletedOrStopped");
353 return waiter.Wait(request);
354 }
355
356 Aws::Utils::WaiterOutcome<Model::DescribeTransformJobOutcome> WaitUntilTransformJobCompletedOrStopped(
357 const Model::DescribeTransformJobRequest& request) {
358 using OutcomeT = Model::DescribeTransformJobOutcome;
359 using RequestT = Model::DescribeTransformJobRequest;
360 Aws::Vector<Aws::UniquePtr<Aws::Utils::Acceptor<OutcomeT>>> acceptors;
361 acceptors.emplace_back(Aws::MakeUnique<Aws::Utils::PathAcceptor<OutcomeT>>(
362 "TransformJobCompletedOrStoppedWaiter", Aws::Utils::WaiterState::SUCCESS, Aws::String("Completed"),
363 [](const Model::DescribeTransformJobOutcome& outcome, const Aws::Utils::ExpectedValue& expected) -> bool {
364 if (!outcome.IsSuccess()) return false;
365 const auto& result = outcome.GetResult();
366 return Model::TransformJobStatusMapper::GetNameForTransformJobStatus(result.GetTransformJobStatus()) ==
367 expected.get<Aws::String>();
368 }));
369 acceptors.emplace_back(Aws::MakeUnique<Aws::Utils::PathAcceptor<OutcomeT>>(
370 "TransformJobCompletedOrStoppedWaiter", Aws::Utils::WaiterState::SUCCESS, Aws::String("Stopped"),
371 [](const Model::DescribeTransformJobOutcome& outcome, const Aws::Utils::ExpectedValue& expected) -> bool {
372 if (!outcome.IsSuccess()) return false;
373 const auto& result = outcome.GetResult();
374 return Model::TransformJobStatusMapper::GetNameForTransformJobStatus(result.GetTransformJobStatus()) ==
375 expected.get<Aws::String>();
376 }));
377 acceptors.emplace_back(Aws::MakeUnique<Aws::Utils::PathAcceptor<OutcomeT>>(
378 "TransformJobCompletedOrStoppedWaiter", Aws::Utils::WaiterState::FAILURE, Aws::String("Failed"),
379 [](const Model::DescribeTransformJobOutcome& outcome, const Aws::Utils::ExpectedValue& expected) -> bool {
380 if (!outcome.IsSuccess()) return false;
381 const auto& result = outcome.GetResult();
382 return Model::TransformJobStatusMapper::GetNameForTransformJobStatus(result.GetTransformJobStatus()) ==
383 expected.get<Aws::String>();
384 }));
385 acceptors.emplace_back(Aws::MakeUnique<Aws::Utils::ErrorAcceptor<OutcomeT>>(
386 "TransformJobCompletedOrStoppedWaiter", Aws::Utils::WaiterState::FAILURE, Aws::String("ValidationException")));
387
388 auto operation = [this](const RequestT& req) { return static_cast<DerivedClient*>(this)->DescribeTransformJob(req); };
389 Aws::Utils::Waiter<RequestT, OutcomeT> waiter(60, 60, std::move(acceptors), operation, "WaitUntilTransformJobCompletedOrStopped");
390 return waiter.Wait(request);
391 }
392};
393} // namespace SageMaker
394} // namespace Aws
Aws::SageMaker::SageMakerWaiter::WaitUntilImageCreated
Aws::Utils::WaiterOutcome< Model::DescribeImageOutcome > WaitUntilImageCreated(const Model::DescribeImageRequest &request)
Definition SageMakerWaiter.h:85
Aws::SageMaker::SageMakerWaiter::WaitUntilImageDeleted
Aws::Utils::WaiterOutcome< Model::DescribeImageOutcome > WaitUntilImageDeleted(const Model::DescribeImageRequest &request)
Definition SageMakerWaiter.h:111
Aws::SageMaker::SageMakerWaiter::WaitUntilTrainingJobCompletedOrStopped
Aws::Utils::WaiterOutcome< Model::DescribeTrainingJobOutcome > WaitUntilTrainingJobCompletedOrStopped(const Model::DescribeTrainingJobRequest &request)
Definition SageMakerWaiter.h:322
Aws::SageMaker::SageMakerWaiter::WaitUntilTransformJobCompletedOrStopped
Aws::Utils::WaiterOutcome< Model::DescribeTransformJobOutcome > WaitUntilTransformJobCompletedOrStopped(const Model::DescribeTransformJobRequest &request)
Definition SageMakerWaiter.h:356
Aws::SageMaker::SageMakerWaiter::WaitUntilNotebookInstanceDeleted
Aws::Utils::WaiterOutcome< Model::DescribeNotebookInstanceOutcome > WaitUntilNotebookInstanceDeleted(const Model::DescribeNotebookInstanceRequest &request)
Definition SageMakerWaiter.h:210
Aws::SageMaker::SageMakerWaiter::WaitUntilEndpointDeleted
Aws::Utils::WaiterOutcome< Model::DescribeEndpointOutcome > WaitUntilEndpointDeleted(const Model::DescribeEndpointRequest &request)
Definition SageMakerWaiter.h:40
Aws::SageMaker::SageMakerWaiter::WaitUntilProcessingJobCompletedOrStopped
Aws::Utils::WaiterOutcome< Model::DescribeProcessingJobOutcome > WaitUntilProcessingJobCompletedOrStopped(const Model::DescribeProcessingJobRequest &request)
Definition SageMakerWaiter.h:285
Aws::SageMaker::SageMakerWaiter::WaitUntilImageVersionDeleted
Aws::Utils::WaiterOutcome< Model::DescribeImageVersionOutcome > WaitUntilImageVersionDeleted(const Model::DescribeImageVersionRequest &request)
Definition SageMakerWaiter.h:187
Aws::SageMaker::SageMakerWaiter::WaitUntilEndpointInService
Aws::Utils::WaiterOutcome< Model::DescribeEndpointOutcome > WaitUntilEndpointInService(const Model::DescribeEndpointRequest &request)
Definition SageMakerWaiter.h:59
Aws::SageMaker::SageMakerWaiter::WaitUntilNotebookInstanceStopped
Aws::Utils::WaiterOutcome< Model::DescribeNotebookInstanceOutcome > WaitUntilNotebookInstanceStopped(const Model::DescribeNotebookInstanceRequest &request)
Definition SageMakerWaiter.h:258
Aws::SageMaker::SageMakerWaiter::WaitUntilNotebookInstanceInService
Aws::Utils::WaiterOutcome< Model::DescribeNotebookInstanceOutcome > WaitUntilNotebookInstanceInService(const Model::DescribeNotebookInstanceRequest &request)
Definition SageMakerWaiter.h:231
Aws::SageMaker::SageMakerWaiter::WaitUntilImageVersionCreated
Aws::Utils::WaiterOutcome< Model::DescribeImageVersionOutcome > WaitUntilImageVersionCreated(const Model::DescribeImageVersionRequest &request)
Definition SageMakerWaiter.h:158
Aws::SageMaker::SageMakerWaiter::WaitUntilImageUpdated
Aws::Utils::WaiterOutcome< Model::DescribeImageOutcome > WaitUntilImageUpdated(const Model::DescribeImageRequest &request)
Definition SageMakerWaiter.h:132
Aws::Utils::Outcome::IsSuccess
bool IsSuccess() const
Aws::Utils::Outcome::GetResult
const R & GetResult() const
Aws::Utils::Waiter::Wait
WaiterOutcome< OutcomeT > Wait(const RequestT &request)
Aws::SageMaker::Model::EndpointStatusMapper::GetNameForEndpointStatus
AWS_SAGEMAKER_API Aws::String GetNameForEndpointStatus(EndpointStatus value)
Aws::SageMaker::Model::ImageStatusMapper::GetNameForImageStatus
AWS_SAGEMAKER_API Aws::String GetNameForImageStatus(ImageStatus value)
Aws::SageMaker::Model::ImageVersionStatusMapper::GetNameForImageVersionStatus
AWS_SAGEMAKER_API Aws::String GetNameForImageVersionStatus(ImageVersionStatus value)
Aws::SageMaker::Model::NotebookInstanceStatusMapper::GetNameForNotebookInstanceStatus
AWS_SAGEMAKER_API Aws::String GetNameForNotebookInstanceStatus(NotebookInstanceStatus value)
Aws::SageMaker::Model::ProcessingJobStatusMapper::GetNameForProcessingJobStatus
AWS_SAGEMAKER_API Aws::String GetNameForProcessingJobStatus(ProcessingJobStatus value)
Aws::SageMaker::Model::TrainingJobStatusMapper::GetNameForTrainingJobStatus
AWS_SAGEMAKER_API Aws::String GetNameForTrainingJobStatus(TrainingJobStatus value)
Aws::SageMaker::Model::TransformJobStatusMapper::GetNameForTransformJobStatus
AWS_SAGEMAKER_API Aws::String GetNameForTransformJobStatus(TransformJobStatus value)
Aws::SageMaker::Model::DescribeImageVersionOutcome
Aws::Utils::Outcome< DescribeImageVersionResult, SageMakerError > DescribeImageVersionOutcome
Definition SageMakerServiceClientModel.h:1000
Aws::SageMaker::Model::DescribeTransformJobOutcome
Aws::Utils::Outcome< DescribeTransformJobResult, SageMakerError > DescribeTransformJobOutcome
Definition SageMakerServiceClientModel.h:1033
Aws::SageMaker::Model::DescribeImageOutcome
Aws::Utils::Outcome< DescribeImageResult, SageMakerError > DescribeImageOutcome
Definition SageMakerServiceClientModel.h:999
Aws::SageMaker::Model::DescribeTrainingJobOutcome
Aws::Utils::Outcome< DescribeTrainingJobResult, SageMakerError > DescribeTrainingJobOutcome
Definition SageMakerServiceClientModel.h:1030
Aws::SageMaker::Model::DescribeNotebookInstanceOutcome
Aws::Utils::Outcome< DescribeNotebookInstanceResult, SageMakerError > DescribeNotebookInstanceOutcome
Definition SageMakerServiceClientModel.h:1017
Aws::SageMaker::Model::DescribeProcessingJobOutcome
Aws::Utils::Outcome< DescribeProcessingJobResult, SageMakerError > DescribeProcessingJobOutcome
Definition SageMakerServiceClientModel.h:1024
Aws::SageMaker::Model::DescribeEndpointOutcome
Aws::Utils::Outcome< DescribeEndpointResult, SageMakerError > DescribeEndpointOutcome
Definition SageMakerServiceClientModel.h:989
Aws::Utils::ExpectedValue
Crt::Variant< int, bool, Aws::String > ExpectedValue
Aws::String
std::basic_string< char, std::char_traits< char >, Aws::Allocator< char > > String
Aws::MakeUnique
UniquePtr< T > MakeUnique(const char *allocationTag, ArgTypes &&... args)
Aws::Vector
std::vector< T, Aws::Allocator< T > > Vector
Generated by doxygen 1.9.8
Privacy | Site terms | Cookie preferences