Skip to content

Commit 098534c

Browse files
committed
Issue #1037 add a bit of logging about kz client reuse in ZooKeeperUserDefinedProcessRepository
1 parent 9e15bd5 commit 098534c

File tree

1 file changed

+2
-0
lines changed

1 file changed

+2
-0
lines changed

openeogeotrellis/user_defined_process_repository.py

+2
Original file line numberDiff line numberDiff line change
@@ -24,6 +24,7 @@ def __init__(self, hosts: List[str], root: str = "/openeo/udps", *, zk_client_re
2424
self._root = root
2525
self._zk_client_reuse = zk_client_reuse
2626
self._zk_client_cache = None
27+
self._log.info(f"ZooKeeperUserDefinedProcessRepository with {self._root=} {self._zk_client_reuse=}")
2728

2829
@staticmethod
2930
def _serialize(spec: dict) -> bytes:
@@ -84,6 +85,7 @@ def _zk_client(self):
8485
create_new_client = (not self._zk_client_reuse) or (self._zk_client_cache is None)
8586
if create_new_client:
8687
kz_retry = KazooRetry(max_tries=10, delay=0.5, backoff=2)
88+
self._log.info(f"ZooKeeperUserDefinedProcessRepository: creating KazooClient ({self._zk_client_reuse=})")
8789
zk = KazooClient(
8890
hosts=self._hosts,
8991
connection_retry=kz_retry,

0 commit comments

Comments
 (0)