googleapis / googleapis/google-cloud-python

Expose StreamingPullManager.load property via StreamingPullFuture

Open
#15,634 2 comments 0 reactions 1 assignee Claimed by @abbrowne126 View on GitHub
api: pubsub
Dominant language
Python
Stars
5.4k
Forks
1.8k
Avg merge
3d 4h
Merged PRs (30d)
122

Description

**Is your feature request related to a problem? Please describe.**
When implementing custom scaling mechanisms in worker-pool workloads, the only current working solution is to count active messages. This is cumbersome and also doesn't account for other reasons why a particular worker may be close to its limits. Using monitoring metrics is not always feasible and imposes longer aggregation periods.

**Describe the solution you'd like**
A public property on `StreamingPullFutire` that provides read-only getter to `__manager.load`

**Describe alternatives you've considered**
Counting total active messages and their cumulative size manually in code.

Contributor guide

Open the contributing guide

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.