@@ -202,7 +202,7 @@ def _load_data_sources():
202
202
203
203
204
204
data_sources , data_sources_df = _load_data_sources ()
205
- data_source_by_id = {d .source : d for d in data_sources }
205
+ data_sources_by_id = {d .source : d for d in data_sources }
206
206
207
207
208
208
def _load_data_signals (sources : List [DataSource ]):
@@ -231,12 +231,11 @@ def _load_data_signals(sources: List[DataSource]):
231
231
data_signals_by_key = {d .key : d for d in data_signals }
232
232
# also add the resolved signal version to the signal lookup
233
233
for d in data_signals :
234
- source = data_source_by_id .get (d .source )
234
+ source = data_sources_by_id .get (d .source )
235
235
if source and source .uses_db_alias :
236
236
data_signals_by_key [(source .db_source , d .signal )] = d
237
237
238
238
239
-
240
239
def get_related_signals (signal : DataSignal ) -> List [DataSignal ]:
241
240
return [s for s in data_signals if s != signal and s .signal_basename == signal .signal_basename ]
242
241
@@ -266,7 +265,7 @@ def create_source_signal_alias_mapper(source_signals: List[SourceSignalPair]) ->
266
265
alias_to_data_sources : Dict [str , List [DataSource ]] = {}
267
266
transformed_pairs : List [SourceSignalPair ] = []
268
267
for pair in source_signals :
269
- source = data_source_by_id .get (pair .source )
268
+ source = data_sources_by_id .get (pair .source )
270
269
if not source or not source .uses_db_alias :
271
270
transformed_pairs .append (pair )
272
271
continue
0 commit comments