add queueing and multi process support (#48)

* add queueing and multi process

* fix some stuff

* fix status

* fix some failure cases

* prevent spurious exception

* add worker id to logs

* fix tests

* some cleanups

* some cleanups, improved test coverage

* fix integration issue

* update version

example.py

@@ -1,6 +1,8 @@
+import time
 from potassium import Potassium, Request, Response
 from transformers import pipeline
 import torch
+import os
 
 app = Potassium("my_app")
 
@@ -28,5 +30,26 @@ def handler(context: dict, request: Request) -> Response:
         status=200
     )
 
+@app.background("/background")
+def background(context: dict, request: Request):
+    time.sleep(5)
+    print('hi')
+
+
+@app.handler("/stream")
+def stream(context: dict, request: Request):
+    def stream():
+        for i in range(100):
+            yield f"{i}\n"
+            time.sleep(1)
+
+
+    return Response(
+        body=stream(),
+        status=200,
+        headers={"Content-Type": "text/plain"}
+    )
+
+
 if __name__ == "__main__":
-    app.serve()
+    app.serve()

potassium/__init__.py

@@ -1,3 +1,4 @@
 from .potassium import *
 from .hooks import *
-from .store import Store, RedisConfig
+from .store import Store, RedisConfig
+from .types import Request, Response

potassium/exceptions.py

@@ -0,0 +1,10 @@
+class InvalidEndpointTypeException(Exception):
+    def __init__(self):
+        super().__init__("Invalid endpoint type. Must be 'handler' or 'background'")
+
+
+class RouteAlreadyInUseException(Exception):
+    def __init__(self):
+        super().__init__("Route already in use")
+
+