Browse Source
Merge pull request #23400 from abpframework/Disable-IsJobExecutionEnabled
Disable background job/worker in data migration environments
pull/23403/head
Engincan VESKE
1 year ago
committed by
GitHub
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
4 changed files with
30 additions and
16 deletions
-
framework/src/Volo.Abp.BackgroundJobs.Abstractions/Volo/Abp/BackgroundJobs/AbpBackgroundJobsAbstractionsModule.cs
-
framework/src/Volo.Abp.BackgroundJobs/Volo/Abp/BackgroundJobs/AbpBackgroundJobsModule.cs
-
framework/src/Volo.Abp.BackgroundWorkers/Volo.Abp.BackgroundWorkers.csproj
-
framework/src/Volo.Abp.BackgroundWorkers/Volo/Abp/BackgroundWorkers/AbpBackgroundWorkersModule.cs
|
|
|
@ -1,6 +1,7 @@ |
|
|
|
using System; |
|
|
|
using System.Collections.Generic; |
|
|
|
using Microsoft.Extensions.DependencyInjection; |
|
|
|
using Volo.Abp.Data; |
|
|
|
using Volo.Abp.Json; |
|
|
|
using Volo.Abp.Modularity; |
|
|
|
using Volo.Abp.MultiTenancy; |
|
|
|
@ -19,6 +20,17 @@ public class AbpBackgroundJobsAbstractionsModule : AbpModule |
|
|
|
RegisterJobs(context.Services); |
|
|
|
} |
|
|
|
|
|
|
|
public override void ConfigureServices(ServiceConfigurationContext context) |
|
|
|
{ |
|
|
|
if (context.Services.IsDataMigrationEnvironment()) |
|
|
|
{ |
|
|
|
Configure<AbpBackgroundJobOptions>(options => |
|
|
|
{ |
|
|
|
options.IsJobExecutionEnabled = false; |
|
|
|
}); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
private static void RegisterJobs(IServiceCollection services) |
|
|
|
{ |
|
|
|
var jobTypes = new List<Type>(); |
|
|
|
|
|
|
|
@ -2,7 +2,6 @@ |
|
|
|
using Microsoft.Extensions.DependencyInjection; |
|
|
|
using Microsoft.Extensions.Options; |
|
|
|
using Volo.Abp.BackgroundWorkers; |
|
|
|
using Volo.Abp.Data; |
|
|
|
using Volo.Abp.DistributedLocking; |
|
|
|
using Volo.Abp.Guids; |
|
|
|
using Volo.Abp.Modularity; |
|
|
|
@ -22,17 +21,6 @@ namespace Volo.Abp.BackgroundJobs; |
|
|
|
)] |
|
|
|
public class AbpBackgroundJobsModule : AbpModule |
|
|
|
{ |
|
|
|
public override void ConfigureServices(ServiceConfigurationContext context) |
|
|
|
{ |
|
|
|
if (context.Services.IsDataMigrationEnvironment()) |
|
|
|
{ |
|
|
|
Configure<AbpBackgroundJobOptions>(options => |
|
|
|
{ |
|
|
|
options.IsJobExecutionEnabled = false; |
|
|
|
}); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
public override async Task OnApplicationInitializationAsync(ApplicationInitializationContext context) |
|
|
|
{ |
|
|
|
if (context.ServiceProvider.GetRequiredService<IOptions<AbpBackgroundJobOptions>>().Value.IsJobExecutionEnabled) |
|
|
|
|
|
|
|
@ -17,6 +17,7 @@ |
|
|
|
</PropertyGroup> |
|
|
|
|
|
|
|
<ItemGroup> |
|
|
|
<ProjectReference Include="..\Volo.Abp.Data\Volo.Abp.Data.csproj" /> |
|
|
|
<ProjectReference Include="..\Volo.Abp.Threading\Volo.Abp.Threading.csproj" /> |
|
|
|
</ItemGroup> |
|
|
|
|
|
|
|
|
|
|
|
@ -1,17 +1,30 @@ |
|
|
|
using System.Threading.Tasks; |
|
|
|
using Microsoft.Extensions.DependencyInjection; |
|
|
|
using Microsoft.Extensions.Options; |
|
|
|
using Volo.Abp.Data; |
|
|
|
using Volo.Abp.Modularity; |
|
|
|
using Volo.Abp.Threading; |
|
|
|
|
|
|
|
namespace Volo.Abp.BackgroundWorkers; |
|
|
|
|
|
|
|
[DependsOn( |
|
|
|
typeof(AbpThreadingModule) |
|
|
|
)] |
|
|
|
typeof(AbpThreadingModule), |
|
|
|
typeof(AbpDataModule) |
|
|
|
)] |
|
|
|
public class AbpBackgroundWorkersModule : AbpModule |
|
|
|
{ |
|
|
|
public async override Task OnApplicationInitializationAsync(ApplicationInitializationContext context) |
|
|
|
public override void ConfigureServices(ServiceConfigurationContext context) |
|
|
|
{ |
|
|
|
if (context.Services.IsDataMigrationEnvironment()) |
|
|
|
{ |
|
|
|
Configure<AbpBackgroundWorkerOptions>(options => |
|
|
|
{ |
|
|
|
options.IsEnabled = false; |
|
|
|
}); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
public override async Task OnApplicationInitializationAsync(ApplicationInitializationContext context) |
|
|
|
{ |
|
|
|
var options = context.ServiceProvider.GetRequiredService<IOptions<AbpBackgroundWorkerOptions>>().Value; |
|
|
|
if (options.IsEnabled) |
|
|
|
@ -22,7 +35,7 @@ public class AbpBackgroundWorkersModule : AbpModule |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
public async override Task OnApplicationShutdownAsync(ApplicationShutdownContext context) |
|
|
|
public override async Task OnApplicationShutdownAsync(ApplicationShutdownContext context) |
|
|
|
{ |
|
|
|
var options = context.ServiceProvider.GetRequiredService<IOptions<AbpBackgroundWorkerOptions>>().Value; |
|
|
|
if (options.IsEnabled) |
|
|
|
|