Merge pull request #177 from timkpaine/tkp/hf

hotfix for embedded event loops

tributary/streaming/graph.py

@@ -105,7 +105,7 @@ def run(self, blocking=True, newloop=False, start=True):
                 if loop.is_running():
 
                     async def wait(task):
-                        await task
+                        return await task
 
                     return asyncio.run_coroutine_threadsafe(wait(task), loop)
                 # block until done