Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion Cargo.lock

Some generated files are not rendered by default. Learn more about how customized files appear on GitHub.

5 changes: 5 additions & 0 deletions proto/sentry_protos/taskbroker/v1/taskbroker.proto
Original file line number Diff line number Diff line change
Expand Up @@ -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;
Comment thread
cursor[bot] marked this conversation as resolved.
}

message SetTaskStatusResponse {
Expand Down
5 changes: 5 additions & 0 deletions rust/src/sentry_protos.taskbroker.v1.rs
Original file line number Diff line number Diff line change
Expand Up @@ -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<u32>,
/// 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<u64>,
}
#[derive(Clone, PartialEq, ::prost::Message)]
pub struct SetTaskStatusResponse {
Expand Down
Loading