mirror of
https://github.com/langgenius/dify.git
synced 2026-05-09 21:28:25 +08:00
rollback unnecessary changes
This commit is contained in:
parent
2c5a9ec1a0
commit
d226a5bdd3
@ -93,7 +93,6 @@ class Subscriber(Protocol):
|
||||
|
||||
@abstractmethod
|
||||
def subscribe(self) -> Subscription:
|
||||
"""Create a new subscription."""
|
||||
pass
|
||||
|
||||
|
||||
|
||||
@ -88,7 +88,8 @@ class _StreamsSubscription(Subscription):
|
||||
# since this method runs in a dedicated thread, acquiring `_lock` inside this method won't cause
|
||||
# deadlock.
|
||||
|
||||
# `"0"` replays all retained entries; `"$"` tails only new messages.
|
||||
# Setting initial last id to `$` to signal redis that we only want new messages.
|
||||
#
|
||||
# ref: https://redis.io/docs/latest/commands/xread/#the-special--id
|
||||
last_id = "$"
|
||||
try:
|
||||
|
||||
Loading…
Reference in New Issue
Block a user