Skip to content

Commit

Permalink
fix
Browse files Browse the repository at this point in the history
  • Loading branch information
guillaume-chervet committed Nov 17, 2024
1 parent f4990d0 commit b3d654f
Showing 1 changed file with 3 additions and 3 deletions.
6 changes: 3 additions & 3 deletions src/SlimFaas/SlimWorker.cs
Original file line number Diff line number Diff line change
Expand Up @@ -103,11 +103,11 @@ private async Task SendHttpRequestToFunction(Dictionary<string, IList<RequestToW
private async Task<long> UpdateTickLastCallIfRequestStillInProgress(int? functionReplicas,
Dictionary<string, int> setTickLastCallCounterDictionnary, string functionDeployment, int numberProcessingTasks)
{
int counterLimit = functionReplicas == 0 ? 10 : 300;
//int counterLimit = functionReplicas == 0 ? 10 : 300;
long queueLength = await slimFaasQueue.CountAsync(functionDeployment);
if (setTickLastCallCounterDictionnary[functionDeployment] > counterLimit)
//if (setTickLastCallCounterDictionnary[functionDeployment] > counterLimit)
{
setTickLastCallCounterDictionnary[functionDeployment] = 0;
//setTickLastCallCounterDictionnary[functionDeployment] = 0;

if (queueLength > 0 || numberProcessingTasks > 0)
{
Expand Down

0 comments on commit b3d654f

Please sign in to comment.