in src/TriggersBinding/MySqlTriggerTargetScaler.cs [37:50]
internal static TargetScalerResult GetScaleResultInternal(int concurrency, long unprocessedChangeCount)
{
if (concurrency < 1)
{
throw new ArgumentOutOfRangeException(nameof(concurrency), $"Unexpected concurrency='{concurrency}' - the value must be > 0.");
}
int targetWorkerCount = (int)Math.Ceiling(unprocessedChangeCount / (decimal)concurrency);
return new TargetScalerResult
{
TargetWorkerCount = targetWorkerCount
};
}