InMemory Crons not being executed consistently

[crazywill32]

I have been using TickerQ to try and run some clean up tasks for a long running windows service (.NET 9 windows service template). I purposely kept all of the functions in the main executable project to allow for easy mapping. However, for the past month or so, I have had very inconsistent performance with the app. Sometimes the system works fine, but then I reboot and it does not. I have motivations for using the in-memory persistence, i.e., I only need the jobs to run if the app is running.

I can see that the source generated code is finding all of the items correctly

However, they are not being triggered.

Any ideas on where to start? I have been bashing my head against this for a month now, will probably have to implement another solution.

Attached is my program.cs with DI registration

using DicomCommunication;
using PTSDoseCalcLib.MessageQueue;
using PTSDoseCalc.Notifications;
using PTSDoseCalc.Notifications.Sender;
using PTSDoseCalc.Persistence;
using PTSDoseCalc.Telemetry;
using TickerQ.DependencyInjection;
using TickerQ.DependencyInjection.Hosting;
using TickerQ.Utilities.Interfaces.Managers;
using TickerQ.Utilities.Models.Ticker;
using PTSDoseCalc.MessageQueue;
using PTSDoseCalc;
using PTSDoseCalcLib.RawDicom;
using PTSDoseCalc.FileWatcher;
using TickerQ.Utilities.Interfaces;
using TickerQ.Utilities.Base;

AppContext.SetSwitch("System.Net.Http.SocketsHttpHandler.Http2UnencryptedSupport", true); //need for another service, very annoying
var hostBuilder = Host.CreateDefaultBuilder(args)
    .UseWindowsService(options =>
    {
      options.ServiceName = "PTSDoseCalc";
    })
    .ConfigureAppConfiguration((context, config) =>
    {
      config.AddEnvironmentVariables();
      var env = context.HostingEnvironment;

      config.SetBasePath(AppContext.BaseDirectory);
      config.AddJsonFile("appsettings.json", optional: true, reloadOnChange: true);
      config.AddJsonFile($"appsettings.{env.EnvironmentName}.json", optional: true);
      config.Build().ValidateDirectoryPathsExist();
    })
    .ConfigureLogging((context, logging) =>
    {
      logging.ClearProviders();
      logging.AddOpenTelemetryLogging(context);
      if (context.HostingEnvironment.IsDevelopment())
      {
        logging.AddSimpleConsole(options =>
        {
          options.SingleLine = true;
          options.IncludeScopes = true;
          options.UseUtcTimestamp = true;
          options.TimestampFormat = "HH:mm:ss ";
        });
      }
      else
      {
        if (OperatingSystem.IsWindows())
        {
          logging.AddEventLog(o =>
          {
            o.SourceName = "PTSDoseCalc";
          });
        }
      }
    })
    .ConfigureServices((context, services) =>
    {
      var config = context.Configuration;
      services.AddWindowsService();

      services.AddTickerQ(options =>
      {

      };
      services.AddHostedService<InputDirectoryWorker>();
      services.AddHostedService<OutputDirectoryWorker>();
      services.AddSingleton<IFileWatcherFactory, DirectoryPollingWatcherFactory>();
      services.AddScoped<RawDicomCheckJob>();
      services.AddSingleton<IPrivateTagHandler, SureCalcPrivateTagHandler>();

      services.AddSingleton(sp =>
      {
        var localEntity = config.GetDicomEntity("Local_Ethos");
        int delay = config.GetSection("Dicom").GetValue<int>("DelayTimeSeconds");
        return ActivatorUtilities.CreateInstance<MeteredDicomCommunicationService>(sp, localEntity, delay);
      });

      services.AddSQLiteAppContext(context);
      services.AddOpenTelemetry(context);
      services.AddMessageQueue();
      services.AddEmailNotificationServices(context);

      services.AddTransient<EthosInputHandler>();
      services.AddSingleton<RawDicomRepository>();
    });


var host = hostBuilder.Build();

// One-time DB setup before service starts
host.CreateSQLiteDb();

//configure cron jobs
host.UseTickerQ();


try
{

  // Run the service
  host.Run();
}
catch (Exception ex)
{
  using var scope2 = host.Services.CreateScope();

  scope2?.ServiceProvider.GetService<ILoggerFactory>()?.CreateLogger<Program>().LogCritical(ex,"Unhandled error in application, application crashing");
}