Skip to content

Commit 5e3cd79

Browse files
committed
stealing avoidNamespaces fix
1 parent 19ddde5 commit 5e3cd79

File tree

1 file changed

+6
-3
lines changed

1 file changed

+6
-3
lines changed

Diff for: src/handlers.py

+6-3
Original file line numberDiff line numberDiff line change
@@ -55,10 +55,11 @@ def on_match_fields(
5555
name: str,
5656
body,
5757
uid: str,
58+
reason: kopf.Reason,
5859
logger: logging.Logger,
5960
**_,
6061
):
61-
if old is None:
62+
if reason == "create":
6263
logger.debug('This is a new object: Ignoring.')
6364
return
6465

@@ -107,14 +108,15 @@ def on_field_data(
107108
new: Dict[str, str],
108109
body: Dict[str, Any],
109110
uid,
111+
reason: kopf.Reason,
110112
logger: logging.Logger,
111113
**_,
112114
):
113-
logger.debug(f'Data changed: {old} -> {new}')
114-
if old is None:
115+
if reason == "create":
115116
logger.debug('This is a new object: Ignoring')
116117
return
117118

119+
logger.debug(f'Data changed: {old} -> {new}')
118120
cached_cluster_secret = csecs_cache.get_cluster_secret(uid)
119121
if cached_cluster_secret is None:
120122
logger.error('Received an event for an unknown ClusterSecret.')
@@ -253,4 +255,5 @@ async def startup_fn(
253255
logger.info(f'Found {len(cluster_secrets)} existing cluster secrets.')
254256

255257
for cluster_secret in cluster_secrets:
258+
logger.info(f'Syncing cluster secret {cluster_secret.get("metadata").get("name")}.')
256259
sync_clustersecret(logger, cluster_secret, csecs_cache, v1, custom_objects_api)

0 commit comments

Comments
 (0)