Skip to content

Commit c097a3d

Browse files
authored
client: add retry policy param to start_workflow (#682)
1 parent b38c608 commit c097a3d

File tree

1 file changed

+5
-1
lines changed

1 file changed

+5
-1
lines changed

client/src/lib.rs

Lines changed: 5 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -49,7 +49,7 @@ use temporal_sdk_core_protos::{
4949
coresdk::{workflow_commands::QueryResult, IntoPayloadsExt},
5050
grpc::health::v1::health_client::HealthClient,
5151
temporal::api::{
52-
common::v1::{Header, Payload, Payloads, WorkflowExecution, WorkflowType},
52+
common::v1::{Header, Payload, Payloads, RetryPolicy, WorkflowExecution, WorkflowType},
5353
enums::v1::{TaskQueueKind, WorkflowIdReusePolicy},
5454
failure::v1::Failure,
5555
operatorservice::v1::operator_service_client::OperatorServiceClient,
@@ -986,6 +986,9 @@ pub struct WorkflowOptions {
986986
/// Optionally enable Eager Workflow Start, a latency optimization using local workers
987987
/// NOTE: Experimental and incompatible with versioning with BuildIDs
988988
pub enable_eager_workflow_start: bool,
989+
990+
/// Optionally set a retry policy for the workflow
991+
pub retry_policy: Option<RetryPolicy>,
989992
}
990993

991994
#[async_trait::async_trait]
@@ -1023,6 +1026,7 @@ impl WorkflowClientTrait for Client {
10231026
search_attributes: options.search_attributes.map(|d| d.into()),
10241027
cron_schedule: options.cron_schedule.unwrap_or_default(),
10251028
request_eager_execution: options.enable_eager_workflow_start,
1029+
retry_policy: options.retry_policy,
10261030
..Default::default()
10271031
},
10281032
)

0 commit comments

Comments
 (0)