using DurableTask.SqlServer;

var connectionString = Environment.GetEnvironmentVariable("DURABLE_SQL_CONNECTION")
    ?? throw new InvalidOperationException("DURABLE_SQL_CONNECTION is required.");
var taskHubName = Environment.GetEnvironmentVariable("DURABLE_SQL_MIGRATOR_HUB")
    ?? "SchemaMigrationProbe";

Console.WriteLine($"Starting DurableTask SQL schema check with probe hub '{taskHubName}'.");
var settings = new SqlOrchestrationServiceSettings(connectionString, taskHubName);
var service = new SqlOrchestrationService(settings);
await service.CreateIfNotExistsAsync();
Console.WriteLine("DurableTask SQL schema is current.");