Reversed publish change in redis

hivesolutions · Mar 8, 2019 · f96b047 · f96b047
1 parent 30d9089
commit f96b047
Showing 1 changed file with 1 addition and 3 deletions.
diff --git a/src/appier/bus.py b/src/appier/bus.py
@@ -141,9 +141,7 @@ def trigger(self, name, *args, **kwargs):
                 kwargs = kwargs
             )
         )
-        publisher = lambda: self._redis.publish(channel, data)
-        if self._delay: self.owner.delay(publisher)
-        else: publisher()
+        self._redis.publish(channel, data)
 
     def _load(self, *args, **kwargs):
         Bus._load(self, *args, **kwargs)