Skip to content

Commit d272c4c

Browse files
chore: bump core (#2162)
1 parent 9ebe5ed commit d272c4c

4 files changed

Lines changed: 76 additions & 32 deletions

File tree

CHANGELOG.md

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -67,3 +67,10 @@ to docs, or any other relevant information.
6767
### Changed
6868

6969
- protobufjs bumped to ^7.6.4
70+
- Updated Core to `5df57f6d`. Package-visible changes from this update include:
71+
- `NativeConnection` initialization now retries without gRPC gzip compression if the server
72+
cannot decompress the eager `GetSystemInfo` call.
73+
- Workflow replay now honors SDK flags already recorded in history even when the server does not
74+
advertise SDK metadata support.
75+
- OTLP metric export failures from Core's periodic metric reader are now logged through Core
76+
telemetry.

packages/core-bridge/Cargo.lock

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

packages/core-bridge/sdk-core

Submodule sdk-core updated 44 files

packages/test/src/test-native-connection.ts

Lines changed: 17 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -69,6 +69,20 @@ async function bindLocalhostTls(server: grpc.Server): Promise<number> {
6969
return await util.promisify(server.bindAsync.bind(server))('127.0.0.1:0', credentials);
7070
}
7171

72+
function addGetSystemInfoMock(server: grpc.Server): void {
73+
server.addService(workflowServiceProtoDescriptor.temporal.api.workflowservice.v1.WorkflowService.service, {
74+
getSystemInfo(
75+
_call: grpc.ServerUnaryCall<
76+
temporal.api.workflowservice.v1.IGetSystemInfoRequest,
77+
temporal.api.workflowservice.v1.IGetSystemInfoResponse
78+
>,
79+
callback: grpc.sendUnaryData<temporal.api.workflowservice.v1.IGetSystemInfoResponse>
80+
) {
81+
callback(null, {});
82+
},
83+
});
84+
}
85+
7286
test('NativeConnection.connect() throws meaningful error when passed invalid address', async (t) => {
7387
await t.throwsAsync(NativeConnection.connect({ address: ':invalid' }), {
7488
instanceOf: TypeError,
@@ -270,6 +284,7 @@ test('all WorkflowService methods are implemented', async (t) => {
270284

271285
test('all OperatorService methods are implemented', async (t) => {
272286
const server = new grpc.Server();
287+
addGetSystemInfoMock(server);
273288
const calledMethods = new Set<string>();
274289
server.addService(
275290
operatorServiceProtoDescriptor.temporal.api.operatorservice.v1.OperatorService.service,
@@ -315,6 +330,7 @@ test('all OperatorService methods are implemented', async (t) => {
315330

316331
test('all HealthService methods are implemented', async (t) => {
317332
const server = new grpc.Server();
333+
addGetSystemInfoMock(server);
318334
const calledMethods = new Set<string>();
319335
server.addService(
320336
healthServiceProtoDescriptor.grpc.health.v1.Health.service,
@@ -364,6 +380,7 @@ test('all HealthService methods are implemented', async (t) => {
364380

365381
test('all TestService methods are implemented', async (t) => {
366382
const server = new grpc.Server();
383+
addGetSystemInfoMock(server);
367384
const calledMethods = new Set<string>();
368385
server.addService(
369386
testServiceProtoDescriptor.temporal.api.testservice.v1.TestService.service,

0 commit comments

Comments
 (0)