[BUG] Configuration subscription stops permanently after the daprd sidecar restarts
Maintainer thường phản hồi trong vòng 3 ngày
Chưa có ai nhận issue này.
Đánh giá
- Độ khó
- 4/5
- Thời gian dự kiến
- 3-5 ngày
- Mức phù hợp với người mới
- 68/100
Hướng nghiên cứu
Start in dapr/clients/grpc/_response.py with ConfigurationWatcher, then trace subscribe_configuration() in both dapr.clients.DaprClient and dapr.aio.clients.DaprClient. Reproduce the stream failure by restarting daprd, and verify that both subscription paths recover and deliver later updates without restarting the application.
Do mô hình lập chỉ mục viết ra từ nội dung của issue.
Mô tả
Expected Behavior
DaprClient.subscribe_configuration() keeps delivering configuration updates for the lifetime of the client.
If the daprd sidecar process exits and comes back (for example an OOM kill of the sidecar container while the application container keeps running), the SDK should re-establish SubscribeConfigurationAlpha1 against the new sidecar and continue calling the handler. Updates that happened while the sidecar was down should be visible on the new subscription, or the application should at least be able to observe that the previous stream ended.
Unary calls such as get_configuration() already work again once the new sidecar is listening. The long-lived configuration subscription should recover the same way.
Actual Behavior
The subscription works after a fresh application start. After daprd restarts, the handler is never called again. The application process stays healthy, so a Kubernetes pod is not recreated, and dynamic config updates are silently lost until the application process itself restarts.
ConfigurationWatcher in dapr/clients/grpc/_response.py reads SubscribeConfigurationAlpha1 on a daemon thread. When the stream raises, the thread prints to stdout and returns:
except Exception:
print(f'{self.store_name} configuration watcher for keys {self.keys} stopped.')
pass
There is no retry. subscribe_configuration() does not retain the ConfigurationWatcher, so nothing is left to start a new stream. The failure is not reported through the Python logger, and the returned subscription id belongs to the dead sidecar.
Seen with dapr Python SDK 1.18.3. Both dapr.clients.DaprClient.subscribe_configuration and dapr.aio.clients.DaprClient.subscribe_configuration use this watcher.
Steps to Reproduce the Problem
- Run an app with a
configuration.rediscomponent and the Python SDK 1.18.3. - Subscribe once at startup:
from dapr.clients import DaprClient
def handler(subscription_id, response):
print("update", subscription_id, {k: v.value for k, v in response.items.items()})
with DaprClient() as client:
subscription_id = client.subscribe_configuration(
store_name="configstore",
keys=["my-key"],
handler=handler,
)
print("subscribed", subscription_id)
# keep the process alive
- Confirm a config change invokes
handler. - Restart only daprd. In Kubernetes this is a sidecar OOM (
OOMKilled) while the app container keeps the same process. Locally, stop and start thedaprdprocess without restarting the app. - Change
my-keyagain after daprd is healthy.
handleris not called. Stdout may contain{store} configuration watcher for keys [...] stopped.Recreating the app process makes updates work again until the next sidecar restart.
Release Note
RELEASE NOTE: FIX Reconnect configuration subscriptions after the Dapr sidecar stream drops.
- Ngôn ngữ chính
- Python
- Star
- 272
- Fork
- 152
- Merge trung bình
- 3 ngày 13 giờ
- Pull request đã merge (30 ngày)
- 11
Chuẩn bị môi trường
Bắt đầu từ đâu
- Đọc hết issue, rồi đọc hướng dẫn đóng góp của dự án.
- Bình luận trên issue rằng bạn sẽ nhận — tránh hai người làm cùng một việc.
- Fork repository và làm thay đổi trên một nhánh.
- Mở pull request có tham chiếu số hiệu của issue.
Issue khác của dapr/python-sdk
-
dapr-ext-workflow good first issue kind/enhancement P2
Độ khó 2/5 1-2 ngày Mức phù hợp với người mới 72/100
dapr/python-sdk#853 · 4 bình luận ·
Maintainer thường phản hồi trong vòng 3 ngày
-
[WORKFLOW SDK FEATURE REQUEST] Retry WaitForInstanceCompletion/Start on a server-sent CANCELLEDĐang mởdapr-ext-workflow kind/enhancement
Độ khó 4/5 3-5 ngày Mức phù hợp với người mới 55/100
dapr/python-sdk#1246 ·
Maintainer thường phản hồi trong vòng 3 ngày
-
kind/bug
Độ khó 4/5 3-5 ngày Mức phù hợp với người mới 65/100
dapr/python-sdk#1233 ·
Maintainer thường phản hồi trong vòng 3 ngày
-
kind/bug
Độ khó 4/5 3-5 ngày Mức phù hợp với người mới 45/100
dapr/python-sdk#1230 ·
Maintainer thường phản hồi trong vòng 3 ngày
-
dapr-ext-workflow kind/enhancement
Độ khó 3/5 1-2 ngày Mức phù hợp với người mới 78/100
dapr/python-sdk#1213 ·
Maintainer thường phản hồi trong vòng 3 ngày
Tất cả issue của dapr/python-sdk
Issue tương tự
-
[Bug] @deck.gl/arcgis dist import resolves to unpublished @deck.gl/core source path (9.3.11, 9.4.0)Đang mở
Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 72/100
Maintainer thường phản hồi trong vòng 1 ngày
-
workflow: a tick's dispatch counts as 'only this step', and no review self-grants a round unattendedĐang mởworkflow
Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 85/100
kristofdegrave/homeassistant-smart-charging#1505 ·
Maintainer thường phản hồi trong vòng 1 ngày
-
New Submission: TropWATERĐang mởmetadata submission
Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 82/100
-
Wrongly named dashboard variableĐang mởbug
Độ khó 2/5 1-3 giờ Mức phù hợp với người mới 65/100
canonical/content-cache-operator#163 · 1 bình luận ·
Maintainer thường phản hồi trong vòng 1 ngày
-
[submission]Đang mởsubmission
Độ khó 1/5 Dưới một giờ Mức phù hợp với người mới 65/100
leanprover/lean-eval-submissions#1852 ·
Maintainer thường phản hồi trong vòng 1 ngày