mirror of
https://github.com/simon987/hexlib.git
synced 2025-04-19 01:36:42 +00:00
Compare commits
No commits in common. "5ee1629c79d05b8c770717a386cfb0b52da22dcb" and "021da84433562bb4a1000183c1b563d1db74cc4a" have entirely different histories.
5ee1629c79
...
021da84433
@ -17,13 +17,9 @@ def get_redis():
|
||||
)
|
||||
|
||||
|
||||
def redis_publish(rdb, item, item_project, item_type, item_subproject=None, item_category="x"):
|
||||
|
||||
item_project = item_project.replace(".", "-")
|
||||
item_subproject = item_subproject.replace(".", "-")
|
||||
|
||||
item_source = item_project if not item_subproject else f"{item_project}.{item_subproject}"
|
||||
def redis_publish(rdb, item, item_source, item_type, item_category="x"):
|
||||
|
||||
item_source = item_source.replace(".", "-")
|
||||
item_type = item_type.replace(".", "-")
|
||||
item_category = item_category.replace(".", "-")
|
||||
|
||||
@ -32,7 +28,7 @@ def redis_publish(rdb, item, item_project, item_type, item_subproject=None, ite
|
||||
rdb.publish(routing_key, item)
|
||||
for arc_list in ARC_LISTS:
|
||||
routing_key = f"{arc_list}.{item_source}.{item_type}.{item_category}"
|
||||
rdb.lpush(routing_key, item)
|
||||
rdb.publish(routing_key, item)
|
||||
|
||||
|
||||
def get_web():
|
||||
|
Loading…
x
Reference in New Issue
Block a user