private void UploadFiles()

in src/Ingestor.cs [936:959]


        private void UploadFiles(DataSource fileRef, IPersistentStorageContainer blobContainer)
        {
            try
            {
                if (blobContainer != null)
                {
                    var blobName = Path.GetFileName(ExtendedPath.RandomizeFileName(fileRef.FileSystemPath));
                    var blobReference = blobContainer.CreateFileRef(blobName);
                    blobReference.UploadFromFileAsync(fileRef.FileSystemPath).WaitEx();
                    fileRef.CloudFileUri = blobReference.GetUnsecureUri();
                    fileRef.SafeCloudFileUri = blobReference.GetFileUri();
                }

                lock (m_listIntermediateSourcesLock)
                {
                    m_listIntermediateSources.Add(fileRef);
                }
                Interlocked.Increment(ref m_filesUploaded);
            }
            catch (Exception ex)
            {
                m_logger.LogError($"UploadFiles failed: {ex.Message}");
            }
        }