v0.0.2b for exospherehost python sdk (#80)

* sdk skeleton

* made version change compulsory for sdk release

Author: NiveditJain

.github/workflows/publish-python-sdk.yml

@@ -5,7 +5,7 @@ on:
     branches:
       - main
     paths:
-      - "python-sdk/**"
+      - "python-sdk/exospherehost/_version.py"
       - ".github/workflows/publish-python-sdk.yml"
 
 permissions:

python-sdk/exospherehost/_version.py

@@ -1 +1 @@
-VERSION = "0.0.1b"
+VERSION = "0.0.2b"

python-sdk/exospherehost/node/__init__.py

@@ -0,0 +1,21 @@
+from abc import ABC, abstractmethod
+from typing import Optional
+
+
+class BaseNode(ABC):
+
+    def __init__(self, unique_name: Optional[str] = None):
+        self.unique_name: Optional[str] = unique_name
+
+    @abstractmethod
+    async def execute(self):
+        pass
+
+    async def next(self):
+        return None  
+
+    def get_unique_name(self) -> str:
+        if self.unique_name is not None:
+            return self.unique_name
+        return self.__class__.__name__
+    

python-sdk/exospherehost/node/status.py

@@ -0,0 +1,9 @@
+CREATED = 'CREATED'
+QUEUED = 'QUEUED'
+EXECUTED = 'EXECUTED'
+NEXT_CREATED = 'NEXT_CREATED'
+RETRY_CREATED = 'RETRY_CREATED'
+TIMEDOUT = 'TIMEDOUT'
+ERRORED = 'ERRORED'
+CANCELLED = 'CANCELLED'
+SUCCESS = 'SUCCESS'

python-sdk/exospherehost/runtime.py

@@ -0,0 +1,23 @@
+from asyncio import Queue
+from typing import List, TypeVar
+
+T = TypeVar('T')
+
+
+class Runtime:
+
+    def __init__(self, namespace: str, state_manager_uri: str, batch_size: int = 16):
+        self._namespace = namespace
+        self._state_manager_uri = state_manager_uri
+        self._batch_size = batch_size
+        self._connected = False
+        self._state_queue = Queue(maxsize=2*batch_size)
+
+    async def connect(self, nodes: List[T]):
+        pass
+
+    async def _enqueue(self, batch_size: int):
+        pass
+
+    def _validate_nodes(self):
+        pass

python-sdk/sample.py

@@ -0,0 +1,22 @@
+from abc import ABC, abstractmethod
+from typing import Optional
+
+class BaseNode(ABC):
+
+    def __init__(self, unique_name: Optional[str] = None):
+        self.unique_name: Optional[str] = unique_name
+
+    def get_unique_name(self) -> str:
+        if self.unique_name is not None:
+            return self.unique_name
+        return self.__class__.__name__
+        
+
+class Foo1(BaseNode):
+
+    def run(self):
+        print(self.get_unique_name())
+
+
+obj = Foo1()
+print(obj.get_unique_name())