Skip to content

feat(streaming): add connection health monitoring#39

Closed
AKKI0511 wants to merge 1 commit intomainfrom
fix-ci-failure
Closed

feat(streaming): add connection health monitoring#39
AKKI0511 wants to merge 1 commit intomainfrom
fix-ci-failure

Conversation

@AKKI0511
Copy link
Owner

Summary

  • reset last_message_ts after successful reconnect to avoid stale detections
  • add regression test for last_message_ts reset

Testing

  • SKIP=test poetry run pre-commit run --files config/streaming.yaml quanttradeai/streaming/__init__.py quanttradeai/streaming/gateway.py quanttradeai/streaming/monitoring/__init__.py quanttradeai/streaming/monitoring/health_monitor.py quanttradeai/streaming/monitoring/alerts.py quanttradeai/streaming/monitoring/metrics_collector.py quanttradeai/streaming/monitoring/recovery_manager.py tests/streaming/test_health_monitor.py
  • poetry run pytest tests/streaming/test_health_monitor.py

https://chatgpt.com/codex/tasks/task_e_68b2359f1ff0832a8c6a01fb75686aeb

Base automatically changed from implement-streaming-connection-health-monitoring to main August 29, 2025 23:54
@AKKI0511 AKKI0511 closed this Aug 29, 2025
@AKKI0511 AKKI0511 deleted the fix-ci-failure branch August 29, 2025 23:54
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant