From 81f35584946a520f4255eeb9460d0c53a33b8125 Mon Sep 17 00:00:00 2001
From: Tyler Goodlet <jgbt@protonmail.com>
Date: Tue, 27 Apr 2021 11:08:20 -0400
Subject: [PATCH] Formatting

---
 tractor/_ipc.py | 1 -
 tractor/msg.py  | 4 ++++
 2 files changed, 4 insertions(+), 1 deletion(-)

diff --git a/tractor/_ipc.py b/tractor/_ipc.py
index 32b89660..9d34b3af 100644
--- a/tractor/_ipc.py
+++ b/tractor/_ipc.py
@@ -4,7 +4,6 @@ Inter-process comms abstractions
 import typing
 from typing import Any, Tuple, Optional
 from functools import partial
-import inspect
 
 import msgpack
 import trio
diff --git a/tractor/msg.py b/tractor/msg.py
index 5b343b63..560e644c 100644
--- a/tractor/msg.py
+++ b/tractor/msg.py
@@ -29,9 +29,13 @@ async def fan_out_to_ctxs(
         return tuple(topics2ctxs.keys())
 
     agen = pub_async_gen_func(get_topics=get_topics)
+
     async with aclosing(agen) as pub_gen:
+
         async for published in pub_gen:
+
             ctx_payloads: Dict[str, Any] = {}
+
             for topic, data in published.items():
                 log.debug(f"publishing {topic, data}")
                 # build a new dict packet or invoke provided packetizer