Skip to content

Commit fb1d9d0

Browse files
committed
Update Core & protos
1 parent c2292ef commit fb1d9d0

14 files changed

Lines changed: 158 additions & 136 deletions

File tree

temporalio/Cargo.lock

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

temporalio/ext/sdk-core

temporalio/ext/src/worker.rs

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -6,23 +6,23 @@ use std::{
66
};
77

88
use crate::{
9-
ROOT_MOD,
109
client::Client,
1110
enter_sync, error, id, new_error,
1211
runtime::{AsyncCommand, Runtime, RuntimeHandle},
1312
util::{AsyncCallback, Struct},
13+
ROOT_MOD,
1414
};
15-
use futures::{StreamExt, stream::BoxStream};
1615
use futures::{future, stream};
16+
use futures::{stream::BoxStream, StreamExt};
1717
use magnus::{
18-
DataTypeFunctions, Error, IntoValue, RArray, RString, RTypedData, Ruby, TypedData, Value,
19-
class, function, method, prelude::*, typed_data,
18+
class, function, method, prelude::*, typed_data, DataTypeFunctions, Error, IntoValue, RArray,
19+
RString, RTypedData, Ruby, TypedData, Value,
2020
};
2121
use prost::Message;
2222
use temporal_sdk_core::{
23+
replay::{HistoryForReplay, ReplayWorkerInput},
2324
ResourceBasedSlotsOptions, ResourceBasedSlotsOptionsBuilder, ResourceSlotOptions,
2425
SlotSupplierOptions, TunerHolder, TunerHolderOptionsBuilder, WorkerConfig, WorkerConfigBuilder,
25-
replay::{HistoryForReplay, ReplayWorkerInput},
2626
};
2727
use temporal_sdk_core_api::{
2828
errors::{PollError, WorkflowErrorType},
@@ -34,7 +34,7 @@ use temporal_sdk_core_api::{
3434
use temporal_sdk_core_protos::coresdk::workflow_completion::WorkflowActivationCompletion;
3535
use temporal_sdk_core_protos::coresdk::{ActivityHeartbeat, ActivityTaskCompletion};
3636
use temporal_sdk_core_protos::temporal::api::history::v1::History;
37-
use tokio::sync::mpsc::{Sender, channel};
37+
use tokio::sync::mpsc::{channel, Sender};
3838
use tokio_stream::wrappers::ReceiverStream;
3939

4040
pub fn init(ruby: &Ruby) -> Result<(), Error> {

temporalio/lib/temporalio/api/batch/v1/message.rb

Lines changed: 1 addition & 1 deletion
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

temporalio/lib/temporalio/api/common/v1/message.rb

Lines changed: 2 additions & 1 deletion
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

0 commit comments

Comments
 (0)