Fixing workflow reload logic

src/modules/Elsa.Scheduling/Services/DefaultTriggerScheduler.cs

@@ -64,6 +64,12 @@ public async Task ScheduleAsync(IEnumerable<StoredTrigger> triggers, Cancellatio
         foreach (var trigger in cronTriggers)
         {
             var payload = trigger.GetPayload<CronTriggerPayload>();
+            if(payload is null)
+            {
+                logger.LogWarning("Cron expression payload is empty. TriggerId: {TriggerId}. Skipping scheduling of this trigger", trigger.Id);
+                continue;
+            }
+
             var cronExpression = payload.CronExpression;
 
             if (string.IsNullOrWhiteSpace(cronExpression))

src/modules/Elsa.Workflows.Runtime/Services/WorkflowDefinitionsReloader.cs

@@ -1,18 +1,11 @@
-using Elsa.Mediator.Contracts;
-using Elsa.Workflows.Runtime.Models;
-using Elsa.Workflows.Runtime.Notifications;
-
-namespace Elsa.Workflows.Runtime;
+namespace Elsa.Workflows.Runtime;
 
 /// <inheritdoc />
-public class WorkflowDefinitionsReloader(IWorkflowDefinitionStorePopulator workflowDefinitionStorePopulator, INotificationSender notificationSender) : IWorkflowDefinitionsReloader
+public class WorkflowDefinitionsReloader(IRegistriesPopulator registriesPopulator) : IWorkflowDefinitionsReloader
 {
     /// <inheritdoc />
     public async Task ReloadWorkflowDefinitionsAsync(CancellationToken cancellationToken)
     {
-        var workflowDefinitions = await workflowDefinitionStorePopulator.PopulateStoreAsync(true, cancellationToken);
-        var reloadedWorkflowDefinitions = workflowDefinitions.Select(ReloadedWorkflowDefinition.FromDefinition).ToList();
-        var notification = new WorkflowDefinitionsReloaded(reloadedWorkflowDefinitions);
-        await notificationSender.SendAsync(notification, cancellationToken);
+        await registriesPopulator.PopulateAsync(cancellationToken);
     }
 }