Compare commits

...

3 Commits

4827 changed files with 145 additions and 163191 deletions

2
.gitignore vendored
View File

@@ -16,3 +16,5 @@ node_modules/
*.log
/tmp/
*.log
scripts/swift_processors/.build/

View File

@@ -86,7 +86,9 @@ class RedisPublisher:
try:
client: redis.Redis = self._client
client.publish(self.channel, json.dumps(asdict(msg)))
json_data = json.dumps(asdict(msg))
client.publish(self.channel, json_data)
client.hset(self.channel, msg.processor, json_data)
return True
except Exception as e:
import sys

View File

@@ -1 +0,0 @@
17505

Some files were not shown because too many files have changed in this diff Show More