Skip to content

Commit

Permalink
build(deps): update to tylisten v2.0
Browse files Browse the repository at this point in the history
  • Loading branch information
JamzumSum committed Nov 5, 2023
1 parent b309f24 commit fa002f9
Show file tree
Hide file tree
Showing 4 changed files with 17 additions and 22 deletions.
23 changes: 9 additions & 14 deletions poetry.lock

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

6 changes: 3 additions & 3 deletions pyproject.toml
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
[tool.poetry]
name = "aioqzone-feed"
version = "1.0.2.dev1"
version = "1.0.3.dev1"
description = "aioqzone plugin that provides higher level apis for processing feeds."
authors = ["aioqzone <[email protected]>"]
license = "AGPL-3.0"
Expand All @@ -15,8 +15,8 @@ documentation = "https://aioqzone.github.io/aioqzone-feed"
[tool.poetry.dependencies]
python = "^3.8"
aioqzone = [
{ version = "^1.5.2.dev3", allow-prereleases = true },
{ version = "^1.5.2.dev3", allow-prereleases = true, extras = [
{ version = "^1.5.4.dev1", allow-prereleases = true },
{ version = "^1.5.4.dev1", allow-prereleases = true, extras = [
"captcha",
], optional = true },
]
Expand Down
6 changes: 3 additions & 3 deletions src/aioqzone_feed/message/feed.py
Original file line number Diff line number Diff line change
Expand Up @@ -26,9 +26,9 @@ def processed_feed(bid: int, feed: FeedContent):
class FeedApiEmitterMixin:
def __init__(self, *args, **kwds) -> None:
super().__init__(*args, **kwds)
self.feed_dropped = raw_feed.new()
self.feed_processed = processed_feed.new()
self.feed_media_updated = processed_feed.new()
self.feed_dropped = raw_feed()
self.feed_processed = processed_feed()
self.feed_media_updated = processed_feed()
self.ch_feed_dispatch = FutureStore()
"""A future store serves as feed dispatch channel."""
self.ch_feed_notify = FutureStore()
Expand Down
4 changes: 2 additions & 2 deletions src/aioqzone_feed/message/heartbeat.py
Original file line number Diff line number Diff line change
Expand Up @@ -24,11 +24,11 @@ def heartbeat_refresh(num: int):
class HeartbeatEmitterMixin:
def __init__(self, *args, **kwds) -> None:
super().__init__(*args, **kwds)
self.hb_failed = heartbeat_failed.new()
self.hb_failed = heartbeat_failed()
"""
This emitter is triggered when the heartbeat fails because of a exception.
"""
self.hb_refresh = heartbeat_refresh.new()
self.hb_refresh = heartbeat_refresh()
"""This emitter is triggered after a heartbeat succeeded and there are new feeds.
Use this event to wait for all dispatch task to be finished, and send received feeds.
"""
Expand Down

0 comments on commit fa002f9

Please sign in to comment.