Asyncio fixes

Author: Fireye04

src/sasquatchbackpack/sasquatch.py

@@ -59,7 +59,13 @@ def __init__(self, address: str) -> None:
         self.address = address
         self.model = redis.from_url(self.address)
 
-        self.loop = asyncio.new_event_loop()
+        # Get Existing loop, create one if it doesn't exist
+        try:
+            self.loop = asyncio.get_running_loop()
+        except RuntimeError:
+            self.loop = asyncio.new_event_loop()
+
+        asyncio.set_event_loop(self.loop)
 
     def store(self, key: str, item: str = "value") -> None:
         """Store a key value pair in the provided redis server.

src/sasquatchbackpack/sources/usgs/commands.py

@@ -199,7 +199,15 @@ def usgs_earthquake_data(
 
     click.echo("Post mode enabled: Sending data...")
     click.echo(f"Querying redis at {backpack_dispatcher.redis.address}")
-    loop = asyncio.new_event_loop()
+
+    # Get Existing loop, create one if it doesn't exist
+    try:
+        loop = asyncio.get_running_loop()
+    except RuntimeError:
+        loop = asyncio.new_event_loop()
+
+    asyncio.set_event_loop(loop)
+
     loop.run_until_complete(backpack_dispatcher.direct_connect())
 
     click.echo("complete")