From 5ab4a0276c9999b4b0aa2ffe79a92d6709b94601 Mon Sep 17 00:00:00 2001 From: Syed Mujtaba Jafri Date: Wed, 7 Aug 2024 05:58:20 +0000 Subject: [PATCH 1/2] feat: Added flag to node type for supporting ephemeral node --- faaskeeper/node.py | 10 ++++++++++ 1 file changed, 10 insertions(+) diff --git a/faaskeeper/node.py b/faaskeeper/node.py index 83328cc..ed0cd63 100644 --- a/faaskeeper/node.py +++ b/faaskeeper/node.py @@ -27,6 +27,16 @@ def __init__(self, path: str): self._children: Optional[List[str]] = None self._created_version: Optional[Version] = None self._modified_version: Optional[Version] = None + self._flag: Optional[int] = None + + @property + def flag(self) -> int: + assert self._flag is not None + return self._flag + + @flag.setter + def flag(self, flag: int): + self._flag = flag @property def path(self) -> str: From 39e2e52b0443fd497469c144f410dcd424e24d88 Mon Sep 17 00:00:00 2001 From: Syed Mujtaba Jafri Date: Wed, 7 Aug 2024 10:52:55 +0000 Subject: [PATCH 2/2] feat: add support for flags in CreateNode op --- faaskeeper/operations.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/faaskeeper/operations.py b/faaskeeper/operations.py index bb0c243..6ffa76b 100644 --- a/faaskeeper/operations.py +++ b/faaskeeper/operations.py @@ -92,6 +92,7 @@ def __init__(self, session_id: str, path: str, value: Optional[bytes], flags: in super().__init__(session_id, path) self._value = value self._value_encoded: Optional[str] = None + self._flags = flags def generate_request(self) -> dict: return { @@ -99,7 +100,7 @@ def generate_request(self) -> dict: "path": self._path, "session_id": self._session_id, "version": -1, - "flags": 0, + "flags": self._flags, "data": self._value, }