Skip to content

Commit 7f17d20

Browse files
fix tests
1 parent 59ac47b commit 7f17d20

File tree

4 files changed

+106
-67
lines changed

4 files changed

+106
-67
lines changed

packages/core-bridge/Cargo.lock

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

packages/core-bridge/Cargo.toml

Lines changed: 11 additions & 11 deletions
Original file line numberDiff line numberDiff line change
@@ -25,28 +25,28 @@ async-trait = "0.1.83"
2525
bridge-macros = { path = "bridge-macros" }
2626
futures = { version = "0.3", features = ["executor"] }
2727
neon = { version = "1.0.0", default-features = false, features = [
28-
"napi-6",
29-
"futures",
28+
"napi-6",
29+
"futures",
3030
] }
31-
opentelemetry = "0.29"
31+
opentelemetry = "0.31"
3232
os_pipe = "1.2.1"
3333
parking_lot = "0.12"
34-
prost = "0.13"
35-
prost-types = "0.13"
34+
prost = "0.14"
35+
prost-types = "0.14"
3636
serde = { version = "1.0", features = ["derive"] }
3737
serde_json = "1.0"
3838
temporal-sdk-core = { version = "*", path = "./sdk-core/core", features = [
39-
"ephemeral-server",
39+
"ephemeral-server",
4040
] }
4141
temporal-client = { version = "*", path = "./sdk-core/client" }
4242
thiserror = "2"
4343
tokio = "1.13"
4444
tokio-stream = "0.1"
45-
tonic = "0.13"
45+
tonic = "0.14"
4646
tracing = "0.1"
4747
tracing-subscriber = { version = "0.3", default-features = false, features = [
48-
"parking_lot",
49-
"env-filter",
50-
"registry",
51-
"ansi",
48+
"parking_lot",
49+
"env-filter",
50+
"registry",
51+
"ansi",
5252
] }

packages/core-bridge/src/worker.rs

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -575,6 +575,7 @@ mod config {
575575
.max_task_queue_activities_per_second(self.max_task_queue_activities_per_second)
576576
.max_worker_activities_per_second(self.max_activities_per_second)
577577
.graceful_shutdown_period(self.shutdown_grace_time)
578+
.skip_client_worker_set_check(true)
578579
.build()
579580
}
580581
}

packages/test/src/test-worker-poller-autoscale.ts

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -48,7 +48,7 @@ test.serial('Can run autoscaling polling worker', async (t) => {
4848
const activity_pollers = matches.filter((l) => l.includes('activity_task'));
4949
t.is(activity_pollers.length, 1, 'Should have exactly one activity poller metric');
5050
t.true(activity_pollers[0].endsWith('2'), 'Activity poller count should be 2');
51-
const workflow_pollers = matches.filter((l) => l.includes('workflow_task'));
51+
const workflow_pollers = matches.filter((l) => l.includes('workflow_task') && l.includes(taskQueue));
5252
t.is(workflow_pollers.length, 2, 'Should have exactly two workflow poller metrics (sticky and non-sticky)');
5353

5454
// There's sticky & non-sticky pollers, and they may have a count of 1 or 2 depending on

0 commit comments

Comments
 (0)