File tree Expand file tree Collapse file tree 2 files changed +5
-9
lines changed Expand file tree Collapse file tree 2 files changed +5
-9
lines changed Original file line number Diff line number Diff line change @@ -459,7 +459,6 @@ def snapshot_evaluator(self) -> SnapshotEvaluator:
459
459
ddl_concurrent_tasks = self .concurrent_tasks ,
460
460
selected_gateway = self .selected_gateway ,
461
461
)
462
-
463
462
return self ._snapshot_evaluator
464
463
465
464
def execution_context (
Original file line number Diff line number Diff line change @@ -122,6 +122,11 @@ def __init__(
122
122
self .adapters = (
123
123
adapters if isinstance (adapters , t .Dict ) else {selected_gateway or "" : adapters }
124
124
)
125
+ self .adapter = (
126
+ next (iter (self .adapters .values ()))
127
+ if not selected_gateway
128
+ else self .adapters [selected_gateway ]
129
+ )
125
130
self .selected_gateway = selected_gateway
126
131
self .ddl_concurrent_tasks = ddl_concurrent_tasks
127
132
@@ -599,14 +604,6 @@ def close(self) -> None:
599
604
except Exception :
600
605
logger .exception ("Failed to close Snapshot Evaluator" )
601
606
602
- @property
603
- def adapter (self ) -> EngineAdapter :
604
- return (
605
- next (iter (self .adapters .values ()))
606
- if not self .selected_gateway
607
- else self .adapters [self .selected_gateway ]
608
- )
609
-
610
607
def _evaluate_snapshot (
611
608
self ,
612
609
snapshot : Snapshot ,
You can’t perform that action at this time.
0 commit comments