in src/Ingestor.cs [961:975]
private void AccumulateObjects(DataSource objectRef)
{
try
{
lock (m_listIntermediateSourcesLock)
{
m_listIntermediateSources.Add(objectRef);
}
Interlocked.Increment(ref m_filesUploaded);
}
catch (Exception ex)
{
m_logger.LogError($"AccumulateObjects failed: {ex.Message}");
}
}