Skip to content

Commit d3d43a1

Browse files
Update wait_for_status_success() call to look at both type and status for status.conditions (#2289) (#2297)
* status should return reason, when condition status is True * based on review comments and offline conversation with dev team * remove unnecessary code * undo retry * addressed review comment * address review comment * update based on reviews Co-authored-by: Debarati Basu-Nag <[email protected]>
1 parent ed80047 commit d3d43a1

File tree

1 file changed

+21
-14
lines changed

1 file changed

+21
-14
lines changed

ocp_resources/node_network_configuration_policy.py

Lines changed: 21 additions & 14 deletions
Original file line numberDiff line numberDiff line change
@@ -377,21 +377,28 @@ def wait_for_status_success(self):
377377
failed_condition_reason = self.Conditions.Reason.FAILED_TO_CONFIGURE
378378
no_match_node_condition_reason = self.Conditions.Reason.NO_MATCHING_NODE
379379

380-
# if we get here too fast there are no conditions, we need to wait.
381-
self.wait_for_configuration_conditions_unknown_or_progressing()
382-
383-
samples = TimeoutSampler(wait_timeout=self.success_timeout, sleep=1, func=lambda: self.status)
384380
try:
385-
for sample in samples:
386-
if sample == self.Conditions.Reason.SUCCESSFULLY_CONFIGURED:
387-
self.logger.info(f"NNCP {self.name} configured Successfully")
388-
return sample
389-
390-
elif sample == no_match_node_condition_reason:
391-
raise NNCPConfigurationFailed(f"{self.name}. Reason: {no_match_node_condition_reason}")
392-
393-
elif sample == failed_condition_reason:
394-
self._process_failed_status(failed_condition_reason=failed_condition_reason)
381+
for sample in TimeoutSampler(
382+
wait_timeout=self.success_timeout,
383+
sleep=5,
384+
func=lambda: next(
385+
(
386+
condition
387+
for condition in self.instance.get("status", {}).get("conditions", [])
388+
if condition and condition["type"] == self.Conditions.Type.AVAILABLE
389+
),
390+
{},
391+
),
392+
):
393+
if sample:
394+
if sample["status"] == self.Condition.Status.TRUE:
395+
self.logger.info(f"NNCP {self.name} configured Successfully")
396+
return sample
397+
elif sample.get("reason") == no_match_node_condition_reason:
398+
raise NNCPConfigurationFailed(f"{self.name}. Reason: {no_match_node_condition_reason}")
399+
400+
elif sample.get("reason") == failed_condition_reason:
401+
self._process_failed_status(failed_condition_reason=failed_condition_reason)
395402

396403
except (TimeoutExpiredError, NNCPConfigurationFailed):
397404
self.logger.error(

0 commit comments

Comments
 (0)