File tree Expand file tree Collapse file tree
Expand file tree Collapse file tree Original file line number Diff line number Diff line change @@ -54,9 +54,13 @@ def pytest_collection_modifyitems(config, items):
5454 nodeid = item .nodeid
5555 # Strip parametrize suffix so the bare test id matches the map.
5656 base = nodeid .split ("[" )[0 ]
57- reason = _DISTRIBUTED_KNOWN_FAILURES .get (base ) or _DISTRIBUTED_KNOWN_FAILURES .get (nodeid )
57+ reason = _DISTRIBUTED_KNOWN_FAILURES .get (
58+ base
59+ ) or _DISTRIBUTED_KNOWN_FAILURES .get (nodeid )
5860 if reason :
59- item .add_marker (skip_distributed (reason = f"distributed-mode known failure: { reason } " ))
61+ item .add_marker (
62+ skip_distributed (reason = f"distributed-mode known failure: { reason } " )
63+ )
6064
6165
6266@pytest .fixture
Original file line number Diff line number Diff line change 1818)
1919from weave .trace_server import clickhouse_trace_server_batched
2020from weave .trace_server import clickhouse_trace_server_migrator as wf_migrator
21- from weave .trace_server import environment as wf_env
2221from weave .trace_server import (
2322 clickhouse_trace_server_settings as ch_settings ,
2423)
24+ from weave .trace_server import environment as wf_env
2525from weave .trace_server .clickhouse_trace_server_batched import ClickHouseTraceServer
2626from weave .trace_server .project_version import project_version
2727from weave .trace_server .secret_fetcher_context import secret_fetcher_context
@@ -234,9 +234,7 @@ def _ch_session_server(
234234 ch_server .ch_client .command (
235235 f"DROP DATABASE IF EXISTS { management_db } { on_cluster } SYNC"
236236 )
237- ch_server .ch_client .command (
238- f"DROP DATABASE IF EXISTS { unique_db } { on_cluster } SYNC"
239- )
237+ ch_server .ch_client .command (f"DROP DATABASE IF EXISTS { unique_db } { on_cluster } SYNC" )
240238 ch_server ._database_ensured = False
241239
242240 def patched_run_migrations ():
You can’t perform that action at this time.
0 commit comments