Skip to content

Commit cb27b40

Browse files
Update release to 1.2.0 and bump core (#379)
* bump core * bump version to 1.2.0 * chore: update readme with ruby 4.0 support
1 parent 5feab3f commit cb27b40

File tree

35 files changed

+539
-220
lines changed

35 files changed

+539
-220
lines changed

README.md

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
<div style="overflow: hidden"><img src="https://raw.githubusercontent.com/temporalio/assets/main/files/w/ruby.png" alt="Temporal Ruby SDK" /></div>
22

3-
![Ruby 3.2 | 3.3 | 3.4](https://img.shields.io/badge/ruby-3.2%20|%203.3%20|%203.4-blue.svg?style=for-the-badge)
3+
![Ruby 3.3 | 3.4 | 4.0](https://img.shields.io/badge/ruby-3.3%20|%203.4%20|%204.0-blue.svg?style=for-the-badge)
44
[![MIT](https://img.shields.io/github/license/temporalio/sdk-ruby.svg?style=for-the-badge)](LICENSE)
55
[![Gem](https://img.shields.io/gem/v/temporalio?style=for-the-badge)](https://rubygems.org/gems/temporalio)
66

@@ -86,7 +86,7 @@ Also see:
8686

8787
### Installation
8888

89-
The Ruby SDK works with Ruby 3.2, 3.3, and 3.4.
89+
The Ruby SDK works with Ruby 3.3, 3.4, and 4.0.
9090

9191
Can require in a Gemfile like:
9292

temporalio/Cargo.lock

Lines changed: 6 additions & 72 deletions
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

temporalio/Cargo.toml

Lines changed: 9 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -12,8 +12,16 @@ license = "MIT"
1212
license-file = "LICENSE"
1313

1414
[workspace.dependencies]
15+
bon = { version = "3", features = ["implied-bounds"] }
1516
derive_builder = "0.20"
16-
derive_more = { version = "2.0", features = ["constructor", "display", "from", "into", "debug", "try_into"] }
17+
derive_more = { version = "2.0", features = [
18+
"constructor",
19+
"display",
20+
"from",
21+
"into",
22+
"debug",
23+
"try_into",
24+
] }
1725
thiserror = "2"
1826
tonic = "0.14"
1927
tonic-prost = "0.14"

temporalio/ext/sdk-core

Submodule sdk-core updated 109 files

temporalio/ext/src/client_rpc_generated.rs

Lines changed: 70 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -18,6 +18,13 @@ impl Client {
1818
) -> Result<(), Error> {
1919
match service {
2020
SERVICE_WORKFLOW => match call.rpc.as_str() {
21+
"count_activity_executions" => rpc_call!(
22+
self,
23+
callback,
24+
call,
25+
WorkflowService,
26+
count_activity_executions
27+
),
2128
"count_workflow_executions" => rpc_call!(
2229
self,
2330
callback,
@@ -31,6 +38,13 @@ impl Client {
3138
"create_workflow_rule" => {
3239
rpc_call!(self, callback, call, WorkflowService, create_workflow_rule)
3340
}
41+
"delete_activity_execution" => rpc_call!(
42+
self,
43+
callback,
44+
call,
45+
WorkflowService,
46+
delete_activity_execution
47+
),
3448
"delete_schedule" => {
3549
rpc_call!(self, callback, call, WorkflowService, delete_schedule)
3650
}
@@ -61,6 +75,13 @@ impl Client {
6175
"deprecate_namespace" => {
6276
rpc_call!(self, callback, call, WorkflowService, deprecate_namespace)
6377
}
78+
"describe_activity_execution" => rpc_call!(
79+
self,
80+
callback,
81+
call,
82+
WorkflowService,
83+
describe_activity_execution
84+
),
6485
"describe_batch_operation" => rpc_call!(
6586
self,
6687
callback,
@@ -179,6 +200,13 @@ impl Client {
179200
WorkflowService,
180201
get_workflow_execution_history_reverse
181202
),
203+
"list_activity_executions" => rpc_call!(
204+
self,
205+
callback,
206+
call,
207+
WorkflowService,
208+
list_activity_executions
209+
),
182210
"list_archived_workflow_executions" => rpc_call!(
183211
self,
184212
callback,
@@ -250,6 +278,20 @@ impl Client {
250278
"pause_activity" => {
251279
rpc_call!(self, callback, call, WorkflowService, pause_activity)
252280
}
281+
"pause_workflow_execution" => rpc_call!(
282+
self,
283+
callback,
284+
call,
285+
WorkflowService,
286+
pause_workflow_execution
287+
),
288+
"poll_activity_execution" => rpc_call!(
289+
self,
290+
callback,
291+
call,
292+
WorkflowService,
293+
poll_activity_execution
294+
),
253295
"poll_activity_task_queue" => rpc_call!(
254296
self,
255297
callback,
@@ -301,6 +343,13 @@ impl Client {
301343
"register_namespace" => {
302344
rpc_call!(self, callback, call, WorkflowService, register_namespace)
303345
}
346+
"request_cancel_activity_execution" => rpc_call!(
347+
self,
348+
callback,
349+
call,
350+
WorkflowService,
351+
request_cancel_activity_execution
352+
),
304353
"request_cancel_workflow_execution" => rpc_call!(
305354
self,
306355
callback,
@@ -454,6 +503,13 @@ impl Client {
454503
WorkflowService,
455504
signal_workflow_execution
456505
),
506+
"start_activity_execution" => rpc_call!(
507+
self,
508+
callback,
509+
call,
510+
WorkflowService,
511+
start_activity_execution
512+
),
457513
"start_batch_operation" => {
458514
rpc_call!(self, callback, call, WorkflowService, start_batch_operation)
459515
}
@@ -467,6 +523,13 @@ impl Client {
467523
"stop_batch_operation" => {
468524
rpc_call!(self, callback, call, WorkflowService, stop_batch_operation)
469525
}
526+
"terminate_activity_execution" => rpc_call!(
527+
self,
528+
callback,
529+
call,
530+
WorkflowService,
531+
terminate_activity_execution
532+
),
470533
"terminate_workflow_execution" => rpc_call!(
471534
self,
472535
callback,
@@ -480,6 +543,13 @@ impl Client {
480543
"unpause_activity" => {
481544
rpc_call!(self, callback, call, WorkflowService, unpause_activity)
482545
}
546+
"unpause_workflow_execution" => rpc_call!(
547+
self,
548+
callback,
549+
call,
550+
WorkflowService,
551+
unpause_workflow_execution
552+
),
483553
"update_activity_options" => rpc_call!(
484554
self,
485555
callback,

temporalio/ext/src/metric.rs

Lines changed: 5 additions & 10 deletions
Original file line numberDiff line numberDiff line change
@@ -219,16 +219,11 @@ fn build_metric_parameters(
219219
description: Option<String>,
220220
unit: Option<String>,
221221
) -> metrics::MetricParameters {
222-
let mut build = metrics::MetricParametersBuilder::default();
223-
build.name(name);
224-
if let Some(description) = description {
225-
build.description(description);
226-
}
227-
if let Some(unit) = unit {
228-
build.unit(unit);
229-
}
230-
// Should be nothing that would fail validation here
231-
build.build().unwrap()
222+
metrics::MetricParameters::builder()
223+
.name(name)
224+
.maybe_description(description)
225+
.maybe_unit(unit)
226+
.build()
232227
}
233228

234229
fn metric_key_values(hash: RHash) -> Result<Vec<metrics::MetricKeyValue>, Error> {

0 commit comments

Comments
 (0)