Add some initial scaffolding

Author: cgillum

.gitmodules

@@ -0,0 +1,3 @@
+[submodule "submodules/durabletask-protobuf"]
+	path = submodules/durabletask-protobuf
+	url = https://github.com/microsoft/durabletask-protobuf

README.md

@@ -10,6 +10,13 @@ As the maintainer of this project, please make a few updates:
 - Understanding the security reporting process in SECURITY.MD
 - Remove this section from the README
 
+### Generating protobufs
+If the gRPC proto definitions need to be updated, the corresponding source code can be regenerated using the following command from the `src/durabletask` directory:
+
+```bash
+python3 -m grpc_tools.protoc --proto_path=../../submodules/durabletask-protobuf/protos  --python_out=. --pyi_out=. --grpc_python_out=. orchestrator_service.proto
+```
+
 ## Contributing
 
 This project welcomes contributions and suggestions.  Most contributions require you to agree to a

setup.py

@@ -0,0 +1,12 @@
+from setuptools import setup
+
+setup(
+    name="durabletask",
+    version="0.1",
+    description="A Durable Task SDK for Python",
+    license="MIT",
+    author="Microsoft",
+    python_requires=">=3.8",
+    packages=["durabletask"],
+    install_requires=[],
+)

src/durabletask/__init__.py

@@ -0,0 +1,3 @@
+"""Durable Task SDK for Python"""
+
+PACKAGE_NAME="durabletask"

src/durabletask/orchestrator_service_pb2.py

@@ -0,0 +1,19 @@
+from abc import ABC, abstractmethod
+from typing import TypeVar, Generic
+
+T = TypeVar('T')
+
+class Task(ABC, Generic[T]):
+    """Abstract base class for asynchronous tasks in a durable orchestration."""
+
+    def __init__(self) -> None:
+        super().__init__()
+        pass
+
+    @abstractmethod
+    def is_complete(self) -> bool:
+        pass
+
+    @abstractmethod
+    def get_result(self) -> T:
+        pass

src/durabletask/orchestrator_service_pb2.pyi

@@ -0,0 +1,26 @@
+import grpc
+import orchestrator_service_pb2
+import orchestrator_service_pb2_grpc
+
+class TaskHubGrpcClient:
+    
+    async def schedule_new_orchestration(self):
+        pass
+
+    async def wait_for_orchestration_start(self):
+        pass
+
+    async def wait_for_orchestration_completion(self):
+        pass
+
+    async def terminate_orchestration(self):
+        pass
+
+    async def suspend_orchestration(self):
+        pass
+
+    async def resume_orchestration(self):
+        pass
+
+    async def raise_orchestration_event(self):
+        pass