According to the docs, a ModifyAckDeadlineRequest can be sent to extend the default 600s max limit.
It's not possible to extend the deadline as the SubscriberClient is pub(crate) and subc is also private.
Ideally this should be attached to the ReceivedMessage itself, so it can be extended while also being able to ack/nack. Another solution would to implement a fn client(&self) -> &SubscriberClient on Subscription
Using subscription.receive is currently impossible to implement on the codebase.
The use case is distributed worker that deals with 1 message at a time, but scales horizontally, but sometimes it can take much longer than 10 minutes to complete (~20 min), and using the streaming subscribe leads to a lot of unnecessary retries
pocesar
commented
1 week ago
https://cloud.google.com/pubsub/docs/lease-management
According to the docs, a ModifyAckDeadlineRequest can be sent to extend the default 600s max limit. It's not possible to extend the deadline as the
SubscriberClientispub(crate)andsubcis also private.Ideally this should be attached to the
ReceivedMessageitself, so it can be extended while also being able toack/nack. Another solution would to implement afn client(&self) -> &SubscriberClientonSubscriptionUsing
subscription.receiveis currently impossible to implement on the codebase.The use case is distributed worker that deals with 1 message at a time, but scales horizontally, but sometimes it can take much longer than 10 minutes to complete (~20 min), and using the streaming subscribe leads to a lot of unnecessary retries