Skip to content

Commit

Permalink
remove retry from withdrawals (#396)
Browse files Browse the repository at this point in the history
  • Loading branch information
RodriFS committed Sep 16, 2024
1 parent d87b071 commit b5737fb
Show file tree
Hide file tree
Showing 4 changed files with 5 additions and 9 deletions.
3 changes: 1 addition & 2 deletions src/Jobs/PerformWithdrawalJob.cs
Original file line number Diff line number Diff line change
Expand Up @@ -66,9 +66,8 @@ public async Task Execute(IJobExecutionContext context)
}

_logger.LogError(e, "Error on {JobName}", nameof(PerformWithdrawalJob));
throw new JobExecutionException(e, false);
}

_logger.LogInformation("{JobName} ended", nameof(PerformWithdrawalJob));
}
}
}
3 changes: 1 addition & 2 deletions src/Pages/Wallets.razor
Original file line number Diff line number Diff line change
Expand Up @@ -1489,8 +1489,7 @@
var map = new JobDataMap();
map.Put("withdrawalRequestId", withdrawalRequest.Id);
var retryList = RetriableJob.ParseRetryListFromString(Constants.JOB_RETRY_INTERVAL_LIST_IN_MINUTES);
var job = RetriableJob.Create<PerformWithdrawalJob>(map, withdrawalRequest.Id.ToString(), retryList);
var job = SimpleJob.Create<PerformWithdrawalJob>(map, withdrawalRequest.Id.ToString());
await scheduler.ScheduleJob(job.Job, job.Trigger);
if (withdrawalRequest != null)
Expand Down
5 changes: 2 additions & 3 deletions src/Pages/Withdrawals.razor
Original file line number Diff line number Diff line change
Expand Up @@ -1012,8 +1012,7 @@
var map = new JobDataMap();
map.Put("withdrawalRequestId", _selectedRequest.Id);

var retryList = RetriableJob.ParseRetryListFromString(Constants.JOB_RETRY_INTERVAL_LIST_IN_MINUTES);
var job = RetriableJob.Create<PerformWithdrawalJob>(map, _selectedRequest.Id.ToString(), retryList);
var job = SimpleJob.Create<PerformWithdrawalJob>(map, _selectedRequest.Id.ToString());
await scheduler.ScheduleJob(job.Job, job.Trigger);

if (_selectedRequest != null)
Expand Down Expand Up @@ -1066,4 +1065,4 @@
_amount = _minimumWithdrawalAmount;
}

}
}
3 changes: 1 addition & 2 deletions src/Rpc/NodeGuardService.cs
Original file line number Diff line number Diff line change
Expand Up @@ -272,8 +272,7 @@ await _coinSelectionService.LockUTXOs(utxos, withdrawalRequest,
{
var map = new JobDataMap();
map.Put("withdrawalRequestId", withdrawalRequest.Id);
var retryList = RetriableJob.ParseRetryListFromString(Constants.JOB_RETRY_INTERVAL_LIST_IN_MINUTES);
var job = RetriableJob.Create<PerformWithdrawalJob>(map, withdrawalRequest.Id.ToString(), retryList);
var job = SimpleJob.Create<PerformWithdrawalJob>(map, withdrawalRequest.Id.ToString());
await _scheduler.ScheduleJob(job.Job, job.Trigger);
}

Expand Down

0 comments on commit b5737fb

Please sign in to comment.