chore: Update Core to latest (#1571)

packages/client/src/async-completion-client.ts

@@ -1,6 +1,5 @@
 import { status as grpcStatus } from '@grpc/grpc-js';
 import { ensureTemporalFailure } from '@temporalio/common';
-import type { temporal } from '@temporalio/proto';
 import {
   encodeErrorToFailure,
   encodeToPayloads,
@@ -216,23 +215,23 @@ export class AsyncCompletionClient extends BaseClient {
     const payloads = await encodeToPayloads(this.dataConverter, details);
     let cancelRequested = false;
     try {
-      let response: temporal.api.workflowservice.v1.RecordActivityTaskHeartbeatResponse;
       if (taskTokenOrFullActivityId instanceof Uint8Array) {
-        response = await this.workflowService.recordActivityTaskHeartbeat({
+        const response = await this.workflowService.recordActivityTaskHeartbeat({
           identity: this.options.identity,
           namespace: this.options.namespace,
           taskToken: taskTokenOrFullActivityId,
           details: { payloads },
         });
+        cancelRequested = !!response.cancelRequested;
       } else {
-        response = await this.workflowService.recordActivityTaskHeartbeatById({
+        const response = await this.workflowService.recordActivityTaskHeartbeatById({
           identity: this.options.identity,
           namespace: this.options.namespace,
           ...taskTokenOrFullActivityId,
           details: { payloads },
         });
+        cancelRequested = !!response.cancelRequested;
       }
-      cancelRequested = !!response.cancelRequested;
     } catch (err) {
       this.handleError(err);
     }

packages/core-bridge/src/runtime.rs

@@ -14,7 +14,7 @@ use temporal_sdk_core::{
     ephemeral_server::EphemeralServer as CoreEphemeralServer,
     init_replay_worker, init_worker,
     replay::{HistoryForReplay, ReplayWorkerInput},
-    ClientOptions, CoreRuntime, RetryClient, WorkerConfig,
+    ClientOptions, CoreRuntime, RetryClient, TokioRuntimeBuilder, WorkerConfig,
 };
 use tokio::sync::{
     mpsc::{channel, unbounded_channel, Sender, UnboundedReceiver, UnboundedSender},
@@ -126,6 +126,10 @@ pub fn start_bridge_loop(
     tokio_builder.enable_all().thread_name("core");
     let telem_opts = telemetry_options.0;
     let meter_maker = telemetry_options.1;
+    let tokio_builder: TokioRuntimeBuilder<Box<dyn Fn() + Send + Sync>> = TokioRuntimeBuilder {
+        inner: tokio_builder,
+        lang_on_thread_start: None,
+    };
     let mut core_runtime =
         CoreRuntime::new(telem_opts, tokio_builder).expect("Failed to create CoreRuntime");