bump version

Author: danielgerlag

src/WorkflowCore/Models/WorkflowOptions.cs

@@ -8,8 +8,6 @@ namespace WorkflowCore.Models
 {
     public class WorkflowOptions
     {
-        internal static readonly int MinimumNumberOfConcurrentWorkflows = 2;
-
         internal Func<IServiceProvider, IPersistenceProvider> PersistanceFactory;
         internal Func<IServiceProvider, IQueueProvider> QueueFactory;
         internal Func<IServiceProvider, IDistributedLockProvider> LockFactory;
@@ -18,7 +16,7 @@ public class WorkflowOptions
         internal TimeSpan PollInterval;
         internal TimeSpan IdleTime;
         internal TimeSpan ErrorRetryInterval;
-        internal int? MaxConcurrentWorkflows;
+        internal int MaxConcurrentWorkflows = Math.Max(Environment.ProcessorCount, 2);
 
         public IServiceCollection Services { get; private set; }
 
@@ -71,13 +69,8 @@ public void UseErrorRetryInterval(TimeSpan interval)
             ErrorRetryInterval = interval;
         }
 
-        public void UseMaxConcurrentWorkflows(int? maxConcurrentWorkflows)
+        public void UseMaxConcurrentWorkflows(int maxConcurrentWorkflows)
         {
-            if (maxConcurrentWorkflows.HasValue && maxConcurrentWorkflows.Value < MinimumNumberOfConcurrentWorkflows)
-            {
-                throw new ArgumentOutOfRangeException($"If {nameof(maxConcurrentWorkflows)} is specified, it cannot be less than ${MinimumNumberOfConcurrentWorkflows}.");
-            }
-
             MaxConcurrentWorkflows = maxConcurrentWorkflows;
         }
     }

src/WorkflowCore/Services/BackgroundTasks/WorkflowConsumer.cs

@@ -15,8 +15,7 @@ internal class WorkflowConsumer : QueueConsumer, IBackgroundTask
         private readonly ObjectPool<IPersistenceProvider> _persistenceStorePool;
         private readonly ObjectPool<IWorkflowExecutor> _executorPool;
 
-        protected override int MaxConcurrentItems => Options.MaxConcurrentWorkflows ?? base.MaxConcurrentItems;
-
+        protected override int MaxConcurrentItems => Options.MaxConcurrentWorkflows;
         protected override QueueType Queue => QueueType.Workflow;
 
         public WorkflowConsumer(IPooledObjectPolicy<IPersistenceProvider> persistencePoolPolicy, IQueueProvider queueProvider, ILoggerFactory loggerFactory, IServiceProvider serviceProvider, IWorkflowRegistry registry, IDistributedLockProvider lockProvider, IPooledObjectPolicy<IWorkflowExecutor> executorPoolPolicy, IDateTimeProvider datetimeProvider, WorkflowOptions options)

src/WorkflowCore/WorkflowCore.csproj

@@ -15,9 +15,9 @@
     <GenerateAssemblyCompanyAttribute>false</GenerateAssemblyCompanyAttribute>
     <GenerateAssemblyProductAttribute>false</GenerateAssemblyProductAttribute>
     <Description>Workflow Core is a light weight workflow engine targeting .NET Standard.</Description>
-    <Version>1.9.2</Version>
-    <AssemblyVersion>1.9.2.0</AssemblyVersion>
-    <FileVersion>1.9.2.0</FileVersion>
+    <Version>1.9.3</Version>
+    <AssemblyVersion>1.9.3.0</AssemblyVersion>
+    <FileVersion>1.9.3.0</FileVersion>
     <PackageReleaseNotes></PackageReleaseNotes>
     <PackageIconUrl>https://github.com/danielgerlag/workflow-core/raw/master/src/logo.png</PackageIconUrl>
   </PropertyGroup>