Proper way to seed tickers

[farisdzafic]

Hi team,

I would like to have the possibility to seed the database with all tickers on startup, with the possibility to modify the seed code and apply changes on the next run.

My idea was to use TickerManager, but I can only insert a ticker on the first run (and got an exception on the next run because the record already exists).
The "Add or Update" feature was not possible because I needed a TickerId to update, which I didn't have at startup.
I can make a query to the database to get the TickerId, but that seems like a workaround.

Perhaps we could consider implementing an AddOrUpdate function in TickerManager or exploring alternative mechanisms.

Is that the way to do it, or am I missing a more elegant approach?

[arcenox]

@farisdzafic I fixed the issue with duplicate at 2.4.4 can you plase try again

[farisdzafic]

Still not what I asked. This is an example of what I'm trying in the Program.cs

.....
app.UseTickerQ();
        
using var scope = app.Services.CreateScope();
var service = scope.ServiceProvider.GetRequiredService<ICronTickerManager<CronTicker>>();
await service.AddAsync(new CronTicker
{
    Function = "MyFunction",
    Expression = "* * * * *",
    Retries = 3,
    RetryIntervals = [3, 5, 15],
    Description = "Description of MyFunction"
});
.....

And on first run (clean database). I get
---> Npgsql.PostgresException (0x80004005): 23505: duplicate key value violates unique constraint "UQ_CronTickerId_ExecutionTime"

But even with this exception, a ticker is created.
If I stop and start the app, I get the same exception, but a new ticker is created, so I have two tickers with the same name.

My question is how to properly seed the database with all my functions?

[arcenox]

@farisdzafic hope this helps:

opt.AddOperationalStore<WebAppDbContext>(ef =>
    {
        ef.UseModelCustomizerForMigrations();
        ef.CancelMissedTickersOnAppStart();
        ef.IgnoreSeedMemoryCronTickers();
        ef.UseTickerSeeder(
            async timeTicker =>
            {
                await timeTicker.AddAsync(new TimeTicker()
                {
                    Id = Guid.NewGuid(),
                    Function = "CleanupLogs",
                    ExecutionTime = DateTime.UtcNow.AddSeconds(5),
                });
            }, cronTicker =>
            {
                cronTicker.AddAsync(new CronTicker()
                {
                    Id = Guid.NewGuid(),
                    Expression = "0 0 * * *",
                    Function = "CleanupLogs"
                });
            });
    });

[arcenox]

Update the version 2.5.x and you will be able to use it

[steveng57]

Sorry I don't have an answer, but I wonder if this is related to an issue I am having...see #168

it appears to be the same constraint that is violated, and almost the same scenario...stop and restart. Your scenario is a few more moving parts than mine.