Push mit letzen Änderungen von MS an Jobrunner

This commit is contained in:
Developer01
2026-07-07 17:09:02 +02:00
parent 4cdca567ef
commit ee47b50363
3 changed files with 25 additions and 0 deletions

View File

@@ -44,6 +44,7 @@ Public Class JobRunner
Await ScheduleJob(Of ADJob)("ADSync", GetJobConfig(JobConfig.JobType.ADSync))
Await ScheduleJob(Of TestJob)("TestJob", GetJobConfig(JobConfig.JobType.Test))
Await ScheduleJob(Of GraphQLJob)("GraphQLJob", GetJobConfig(JobConfig.JobType.GraphQL))
Await ScheduleJob(Of TestJob)("API_SQL", GetJobConfig(JobConfig.JobType.API_SQL))
' [END] Job Scheduling
Catch ex As Exception

View File

@@ -108,6 +108,7 @@
<ItemGroup>
<Compile Include="Config.vb" />
<Compile Include="JobRunner.vb" />
<Compile Include="Jobs\APISQLJob.vb" />
<Compile Include="Jobs\GraphQLJob.vb" />
<Compile Include="Jobs\ADJob.vb" />
<Compile Include="Jobs\TestJob.vb" />

View File

@@ -0,0 +1,23 @@
Imports DigitalData.Modules.Database
Imports DigitalData.Modules.Jobs
Imports DigitalData.Modules.Logging
Imports Quartz
Public Class APISQLJob
Implements Quartz.IJob
Public Function Execute(context As IJobExecutionContext) As Task Implements Quartz.IJob.Execute
Dim oJobData = context.MergedJobDataMap
Dim oLogConfig As LogConfig = oJobData.Item("LogConfig")
Dim oMSSQL As MSSQLServer = oJobData.Item("MSSQL")
Dim oArgs As Dictionary(Of String, String) = oJobData.Item("Args")
Dim oJobArgs = New APISQLArgs With {
.ProfileID = oArgs.Item("ProfileID")
}
Dim oGraphQLJob As New Modules.Jobs.API_DEXSQLJob(oLogConfig, oMSSQL)
oGraphQLJob.StartDexAPISQL(oJobArgs)
Return Task.FromResult(True)
End Function
End Class