diff --git a/Cargo.lock b/Cargo.lock index 3016fc3e..14bd82d1 100644 --- a/Cargo.lock +++ b/Cargo.lock @@ -717,7 +717,7 @@ checksum = "955d28af4278de8121b7ebeb796b6a45735dc01436d898801014aced2773a3d6" [[package]] name = "sentry_protos" -version = "0.9.0" +version = "0.10.0" dependencies = [ "prost", "prost-types", diff --git a/proto/sentry_protos/taskbroker/v1/taskbroker.proto b/proto/sentry_protos/taskbroker/v1/taskbroker.proto index bb17e313..82a00528 100644 --- a/proto/sentry_protos/taskbroker/v1/taskbroker.proto +++ b/proto/sentry_protos/taskbroker/v1/taskbroker.proto @@ -131,6 +131,11 @@ message SetTaskStatusRequest { // to communicate the retry policy for tasks from raw topics that // don't have retry_state embedded in the message. optional uint32 max_attempts = 4; + + // Duration in seconds to wait before retrying the task. + // When status is RETRY and this field is set, the broker will update + // the activation's retry_state.delay_on_retry with this value. + optional uint64 delay_on_retry = 5; } message SetTaskStatusResponse { diff --git a/rust/src/sentry_protos.taskbroker.v1.rs b/rust/src/sentry_protos.taskbroker.v1.rs index 2d234096..1fa5cc51 100644 --- a/rust/src/sentry_protos.taskbroker.v1.rs +++ b/rust/src/sentry_protos.taskbroker.v1.rs @@ -113,6 +113,11 @@ pub struct SetTaskStatusRequest { /// don't have retry_state embedded in the message. #[prost(uint32, optional, tag = "4")] pub max_attempts: ::core::option::Option, + /// Duration in seconds to wait before retrying the task. + /// When status is RETRY and this field is set, the broker will update + /// the activation's retry_state.delay_on_retry with this value. + #[prost(uint64, optional, tag = "5")] + pub delay_on_retry: ::core::option::Option, } #[derive(Clone, PartialEq, ::prost::Message)] pub struct SetTaskStatusResponse {