Skip to content
This repository was archived by the owner on Jul 19, 2024. It is now read-only.

Update DefaultDataFlowNetwork.cs #58

Open
rsammut wants to merge 1 commit into
base: master
Choose a base branch
from
Open

Update DefaultDataFlowNetwork.cs #58

Changes from all commits
Commits
Show all changes
1 commit
Select commit
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
10 changes: 6 additions & 4 deletions DIXFSamples/RecurringIntegrationApp/Runtime/DefaultDataFlowNetwork.cs
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -189,11 +189,11 @@ private async Task StatusPollerElapsed(object sender, ElapsedEventArgs e)
if (jobStatusDetail != null)
{
// post process the status received
var postProcessSucceeded = await postProcessMessageAsync(jobStatusDetail, item.Value);
var postProcessFinished= await postProcessMessageAsync(jobStatusDetail, item.Value);

// If the status received is any of the completion state (any of the error state or processed state)
// the treat processing to be complete and remove the item from the tracked dictionary
if (postProcessSucceeded)
if (postProcessFinished)
{
ClientDataMessage _removed;

Expand Down Expand Up @@ -328,7 +328,7 @@ private async Task<DataJobStatusDetail> getStatus(string messageId)
/// </summary>
/// <param name="jobStatusDetail">DataJobStatusDetail object</param>
/// <param name="fileName">Name of the file whose status is being processed</param>
/// <returns>Is post processing successful or not</returns>
/// <returns>Is post processing finished (successful or not)</returns>
private async Task<bool> postProcessMessageAsync(DataJobStatusDetail jobStatusDetail,
ClientDataMessage dataMessage)
{
Expand Down Expand Up @@ -372,7 +372,9 @@ private async Task<bool> postProcessMessageAsync(DataJobStatusDetail jobStatusDe

await this.moveDataToTargetAsync(dataMessage, targetDataMessage);

await this.updateStatsAsync(jobStatusDetail, StatType.Failure, targetDataMessage);
await this.updateStatsAsync(jobStatusDetail, StatType.Failure, targetDataMessage);

retVal = true;
}
break;
}
Expand Down