From a1178a54990d0a0e90fb8327504f69502b7458a7 Mon Sep 17 00:00:00 2001 From: Mayuri Goraviyala Date: Thu, 11 Sep 2025 11:13:34 +0530 Subject: [PATCH 1/4] [patch] State Attribute Error Resolution --- src/mas/devops/olm.py | 11 ++++++++--- 1 file changed, 8 insertions(+), 3 deletions(-) diff --git a/src/mas/devops/olm.py b/src/mas/devops/olm.py index 5481000b..acfa67ff 100644 --- a/src/mas/devops/olm.py +++ b/src/mas/devops/olm.py @@ -156,12 +156,17 @@ def applySubscription(dynClient: DynamicClient, namespace: str, packageName: str # Wait for Subscription to complete logger.debug(f"Waiting for Subscription {name} in {namespace}") - subscriptionResource = subscriptionsAPI.get(name=name, namespace=namespace) - while subscriptionResource.status.state != "AtLatestKnown": + while True: subscriptionResource = subscriptionsAPI.get(name=name, namespace=namespace) + + if subscriptionResource.status.state == "AtLatestKnown": + logger.debug(f"Subscription ready for {name} in {namespace} ") + return subscriptionResource + + logger.debug(f"Subscription ready not yet for {name} in {namespace} ") sleep(30) - return subscriptionResource + def deleteSubscription(dynClient: DynamicClient, namespace: str, packageName: str) -> None: From 70907c51535aa62466af7aca8ee2fc42e6be13d8 Mon Sep 17 00:00:00 2001 From: Mayuri Goraviyala Date: Thu, 11 Sep 2025 11:39:32 +0530 Subject: [PATCH 2/4] [patch] pre commit file change --- src/mas/devops/olm.py | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/src/mas/devops/olm.py b/src/mas/devops/olm.py index acfa67ff..30337c44 100644 --- a/src/mas/devops/olm.py +++ b/src/mas/devops/olm.py @@ -162,12 +162,10 @@ def applySubscription(dynClient: DynamicClient, namespace: str, packageName: str if subscriptionResource.status.state == "AtLatestKnown": logger.debug(f"Subscription ready for {name} in {namespace} ") return subscriptionResource - + logger.debug(f"Subscription ready not yet for {name} in {namespace} ") sleep(30) - - def deleteSubscription(dynClient: DynamicClient, namespace: str, packageName: str) -> None: labelSelector = f"operators.coreos.com/{packageName}.{namespace}" From bc4c544e6646565e5d9a05feaba03b4eb623536b Mon Sep 17 00:00:00 2001 From: Mayuri Goraviyala Date: Wed, 17 Sep 2025 12:27:09 +0530 Subject: [PATCH 3/4] [patch] Error Fixed for subscription status --- src/mas/devops/olm.py | 7 ++++--- 1 file changed, 4 insertions(+), 3 deletions(-) diff --git a/src/mas/devops/olm.py b/src/mas/devops/olm.py index 30337c44..dadc9266 100644 --- a/src/mas/devops/olm.py +++ b/src/mas/devops/olm.py @@ -158,12 +158,13 @@ def applySubscription(dynClient: DynamicClient, namespace: str, packageName: str logger.debug(f"Waiting for Subscription {name} in {namespace}") while True: subscriptionResource = subscriptionsAPI.get(name=name, namespace=namespace) + state = getattr(subscriptionResource.status, "state", None) - if subscriptionResource.status.state == "AtLatestKnown": - logger.debug(f"Subscription ready for {name} in {namespace} ") + if state == "AtLatestKnown": + logger.debug(f"Subscription {name} in {namespace} reached state: {state}") return subscriptionResource - logger.debug(f"Subscription ready not yet for {name} in {namespace} ") + logger.debug(f"Subscription {name} in {namespace} not ready yet (state = {state}), retrying...") sleep(30) From dd81601148b535a133651be8d3230c111d92c016 Mon Sep 17 00:00:00 2001 From: Mayuri Goraviyala Date: Wed, 17 Sep 2025 12:33:22 +0530 Subject: [PATCH 4/4] [patch] pre commit changes --- src/mas/devops/olm.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/mas/devops/olm.py b/src/mas/devops/olm.py index dadc9266..844e4343 100644 --- a/src/mas/devops/olm.py +++ b/src/mas/devops/olm.py @@ -164,7 +164,7 @@ def applySubscription(dynClient: DynamicClient, namespace: str, packageName: str logger.debug(f"Subscription {name} in {namespace} reached state: {state}") return subscriptionResource - logger.debug(f"Subscription {name} in {namespace} not ready yet (state = {state}), retrying...") + logger.debug(f"Subscription {name} in {namespace} not ready yet (state = {state}), retrying...") sleep(30)