Skip to content

Commit 1aa4468

Browse files
committed
moved call to SetMoved to earlier in process
Signed-off-by: Neil South <neil.south@answerdigital.com>
1 parent e9855a3 commit 1aa4468

File tree

2 files changed

+3
-2
lines changed

2 files changed

+3
-2
lines changed

src/InformaticsGateway/Services/Storage/ObjectUploadService.cs

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -262,8 +262,9 @@ await _storageService.PutObjectAsync(
262262
storageObjectMetadata.ContentType,
263263
metadata,
264264
cancellationToken).ConfigureAwait(false);
265-
storageObjectMetadata.SetUploaded(_configuration.Value.Storage.TemporaryStorageBucket);
265+
storageObjectMetadata.SetUploaded(_configuration.Value.Storage.TemporaryStorageBucket); // deletes local file
266266
_logger.UploadedFileToTemporaryStore(storageObjectMetadata.TemporaryPath);
267+
storageObjectMetadata.SetMoved(_configuration.Value.Storage.StorageServiceBucketName);
267268
})
268269
.ConfigureAwait(false);
269270
}

tests/Integration.Test/Common/DicomCStoreDataClient.cs

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -62,7 +62,7 @@ public async Task SendAsync(DataProvider dataProvider, params object[] args)
6262
var failureStatus = new List<DicomStatus>();
6363
for (int i = 0; i < associations; i++)
6464
{
65-
var files = dataProvider.DicomSpecs.Files.Skip(i * filesPerAssociations).Take(filesPerAssociations).ToList();
65+
var files = dataProvider.DicomSpecs.Files.Skip(i * filesPerAssociations).Take(filesPerAssociations).ToList(); // .Take(20)
6666
if (i + 1 == associations && dataProvider.DicomSpecs.Files.Count > (i + 1) * filesPerAssociations)
6767
{
6868
files.AddRange(dataProvider.DicomSpecs.Files.Skip(i * filesPerAssociations));

0 commit comments

Comments
 (0)