diff --git a/harmoney/router/router.py b/harmoney/router/router.py index 1a847f8..3fc60ca 100644 --- a/harmoney/router/router.py +++ b/harmoney/router/router.py @@ -46,7 +46,7 @@ class _Router: l.release() try: while True: - # add this id back into available id pools using a shared list. + # add this id back into available id pools using a shared list. Implement custom error types/ use existing ones to define pre func call disconnect(runner crash/close before running current arguments) or post func call (crash due to calling current args). If pre, strictly add them back to task queue. else, add back conditionally. reqID, data = await self.taskQueue.get() runnerCounter += 1 print(f"Runr {runnerID} Counter: {runnerCounter}") @@ -57,7 +57,6 @@ class _Router: raise Exception( f"Runner {runnerID} Crashed!! Check for function error logs on the Runner." ) - self.returnDict[reqID] = pkl.loads(base64.b64decode(retValue["bytes"])) except Exception as e: print(e)