7
7
from typing import List , cast
8
8
from urllib .request import urlopen
9
9
10
- from temporalio import activity , workflow
10
+ from temporalio import workflow
11
11
from temporalio .client import Client
12
12
from temporalio .runtime import (
13
13
LogForwardingConfig ,
@@ -35,14 +35,18 @@ async def test_different_runtimes(client: Client):
35
35
client1 = await Client .connect (
36
36
client .service_client .config .target_host ,
37
37
namespace = client .namespace ,
38
- runtime = Runtime (telemetry = TelemetryConfig (metrics = PrometheusConfig (bind_address = prom_addr1 ))),
38
+ runtime = Runtime (
39
+ telemetry = TelemetryConfig (metrics = PrometheusConfig (bind_address = prom_addr1 ))
40
+ ),
39
41
)
40
42
41
43
prom_addr2 = f"127.0.0.1:{ find_free_port ()} "
42
44
client2 = await Client .connect (
43
45
client .service_client .config .target_host ,
44
46
namespace = client .namespace ,
45
- runtime = Runtime (telemetry = TelemetryConfig (metrics = PrometheusConfig (bind_address = prom_addr2 ))),
47
+ runtime = Runtime (
48
+ telemetry = TelemetryConfig (metrics = PrometheusConfig (bind_address = prom_addr2 ))
49
+ ),
46
50
)
47
51
48
52
async def run_workflow (client : Client ):
@@ -95,12 +99,19 @@ async def log_queue_len() -> int:
95
99
# Check the expected records
96
100
await assert_eq_eventually (2 , log_queue_len )
97
101
assert log_queue_list [0 ].levelno == logging .INFO
98
- assert log_queue_list [0 ].message .startswith ("[sdk_core::temporal_sdk_bridge::runtime] info1" )
99
- assert log_queue_list [0 ].name == f"{ logger .name } -sdk_core::temporal_sdk_bridge::runtime"
102
+ assert log_queue_list [0 ].message .startswith (
103
+ "[sdk_core::temporal_sdk_bridge::runtime] info1"
104
+ )
105
+ assert (
106
+ log_queue_list [0 ].name
107
+ == f"{ logger .name } -sdk_core::temporal_sdk_bridge::runtime"
108
+ )
100
109
assert log_queue_list [0 ].created == log_queue_list [0 ].temporal_log .time # type: ignore
101
110
assert log_queue_list [0 ].temporal_log .fields == {"extra_data" : "extra1" } # type: ignore
102
111
assert log_queue_list [1 ].levelno == logging .INFO
103
- assert log_queue_list [1 ].message .startswith ("[sdk_core::temporal_sdk_bridge::runtime] info3" )
112
+ assert log_queue_list [1 ].message .startswith (
113
+ "[sdk_core::temporal_sdk_bridge::runtime] info3"
114
+ )
104
115
105
116
# Clear logs and enable debug and try again
106
117
log_queue_list .clear ()
@@ -110,11 +121,17 @@ async def log_queue_len() -> int:
110
121
runtime ._core_runtime .write_test_info_log ("info6" , "extra6" )
111
122
await assert_eq_eventually (3 , log_queue_len )
112
123
assert log_queue_list [0 ].levelno == logging .INFO
113
- assert log_queue_list [0 ].message .startswith ("[sdk_core::temporal_sdk_bridge::runtime] info4" )
124
+ assert log_queue_list [0 ].message .startswith (
125
+ "[sdk_core::temporal_sdk_bridge::runtime] info4"
126
+ )
114
127
assert log_queue_list [1 ].levelno == logging .DEBUG
115
- assert log_queue_list [1 ].message .startswith ("[sdk_core::temporal_sdk_bridge::runtime] debug5" )
128
+ assert log_queue_list [1 ].message .startswith (
129
+ "[sdk_core::temporal_sdk_bridge::runtime] debug5"
130
+ )
116
131
assert log_queue_list [2 ].levelno == logging .INFO
117
- assert log_queue_list [2 ].message .startswith ("[sdk_core::temporal_sdk_bridge::runtime] info6" )
132
+ assert log_queue_list [2 ].message .startswith (
133
+ "[sdk_core::temporal_sdk_bridge::runtime] info6"
134
+ )
118
135
119
136
120
137
@workflow .defn
@@ -155,7 +172,9 @@ async def test_runtime_task_fail_log_forwarding(client: Client):
155
172
156
173
# Wait for log to appear
157
174
async def has_log () -> bool :
158
- return any (l for l in log_queue_list if "Failing workflow task" in l .message )
175
+ return any (
176
+ l for l in log_queue_list if "Failing workflow task" in l .message
177
+ )
159
178
160
179
await assert_eq_eventually (True , has_log )
161
180
0 commit comments