leader.cs

protected override async Task ExecuteAsync(CancellationToken stoppingToken)
{
    // Don't try to start right off the bat
    await Task.Delay(_settings.FirstPollingTime, stoppingToken);

    _connection = new NpgsqlConnection(_settings.ConnectionString);
    await _connection.OpenAsync(stoppingToken);

    while (!stoppingToken.IsCancellationRequested)
    {
        var state = await _process.State();
        if (state != ProcessState.Active)
        {
            // If you can take the global lock, start
            // the process
            if (await _connection.TryGetGlobalLock(_settings.LockId, cancellation: stoppingToken))
            {
                await _process.Start(_connection);
            }
        }

        await Task.Delay(_settings.OwnershipPollingTime, stoppingToken);
    }

    if (_connection.State != ConnectionState.Closed)
    {
        await _connection.DisposeAsync();
    }

}