Skip to content

Commit

Permalink
[Storage][DataMovement] Refactor Job Part Plan file schema (Azure#39606)
Browse files Browse the repository at this point in the history
  • Loading branch information
jalauzon-msft authored and DevArjun23 committed Nov 14, 2023
1 parent 0b1ffb3 commit 02a2bfc
Show file tree
Hide file tree
Showing 31 changed files with 453 additions and 2,749 deletions.
15 changes: 6 additions & 9 deletions sdk/storage/Azure.Storage.DataMovement/src/JobPartInternal.cs
Original file line number Diff line number Diff line change
Expand Up @@ -451,20 +451,17 @@ public async virtual Task CleanupAbortedJobPartAsync()
/// <summary>
/// Serializes the respective job part and adds it to the checkpointer.
/// </summary>
/// <param name="chunksTotal">Number of chunks in the job part.</param>
/// <returns></returns>
public async virtual Task AddJobPartToCheckpointerAsync(int chunksTotal)
public async virtual Task AddJobPartToCheckpointerAsync()
{
JobPartPlanHeader header = this.ToJobPartPlanHeader(jobStatus: JobPartStatus);
JobPartPlanHeader header = this.ToJobPartPlanHeader();
using (Stream stream = new MemoryStream())
{
header.Serialize(stream);
await _checkpointer.AddNewJobPartAsync(
transferId: _dataTransfer.Id,
partNumber: PartNumber,
chunksTotal: chunksTotal,
headerStream: stream,
cancellationToken: _cancellationToken).ConfigureAwait(false);
transferId: _dataTransfer.Id,
partNumber: PartNumber,
headerStream: stream,
cancellationToken: _cancellationToken).ConfigureAwait(false);
}
}

Expand Down

This file was deleted.

This file was deleted.

This file was deleted.

This file was deleted.

This file was deleted.

Loading

0 comments on commit 02a2bfc

Please sign in to comment.