diff --git a/src/Databento.Client/DataSources/FileDataSource.cs b/src/Databento.Client/DataSources/FileDataSource.cs index 402d785..d4132f4 100644 --- a/src/Databento.Client/DataSources/FileDataSource.cs +++ b/src/Databento.Client/DataSources/FileDataSource.cs @@ -200,14 +200,15 @@ public Task ReconnectAsync(CancellationToken cancellationToken = default) private SymbolMappingMessage CreateSymbolMappingMessage(SymbolMapping mapping) { - // Get first interval for instrument ID - var interval = mapping.Intervals.FirstOrDefault(); - - // When StypeOut is InstrumentId, interval.Symbol contains the numeric ID - uint instrumentId = 0; - if (interval != null && _metadata?.StypeOut == SType.InstrumentId) + // Get first interval for instrument ID and when StypeOut is InstrumentId, interval.Symbol contains the numeric ID + uint instrumentId; + if (mapping.Intervals.Count > 0 && _metadata?.StypeOut == SType.InstrumentId) + { + uint.TryParse(mapping.Intervals[0].Symbol, out instrumentId); + } + else { - uint.TryParse(interval.Symbol, out instrumentId); + instrumentId = 0; } return new SymbolMappingMessage