diff --git a/src/DurableTask.Netherite.AzureFunctions/NetheriteProvider.cs b/src/DurableTask.Netherite.AzureFunctions/NetheriteProvider.cs index da6ec05b..4843c580 100644 --- a/src/DurableTask.Netherite.AzureFunctions/NetheriteProvider.cs +++ b/src/DurableTask.Netherite.AzureFunctions/NetheriteProvider.cs @@ -29,7 +29,7 @@ class NetheriteProvider : DurabilityProvider public NetheriteProvider( NetheriteOrchestrationService service, NetheriteOrchestrationServiceSettings settings) - : base("Netherite", service, service, settings.ResolvedStorageConnectionString) + : base("Netherite", service, service, settings.StorageConnectionName) { this.Service = service; this.Settings = settings; diff --git a/src/DurableTask.Netherite.AzureFunctions/NetheriteProviderFactory.cs b/src/DurableTask.Netherite.AzureFunctions/NetheriteProviderFactory.cs index adb9afdb..2598a8f6 100644 --- a/src/DurableTask.Netherite.AzureFunctions/NetheriteProviderFactory.cs +++ b/src/DurableTask.Netherite.AzureFunctions/NetheriteProviderFactory.cs @@ -135,7 +135,7 @@ public DurabilityProvider GetDurabilityProvider() var key = new DurableClientAttribute() { TaskHub = settings.HubName, - ConnectionName = settings.ResolvedStorageConnectionString, + ConnectionName = settings.StorageConnectionName, }; this.defaultProvider = this.cachedProviders.GetOrAdd(key, _ => @@ -154,7 +154,7 @@ public DurabilityProvider GetDurabilityProvider(DurableClientAttribute attribute var settings = this.GetNetheriteOrchestrationServiceSettings(attribute.TaskHub); if (string.Equals(this.defaultProvider.Settings.HubName, settings.HubName, StringComparison.OrdinalIgnoreCase) && - string.Equals(this.defaultProvider.Settings.ResolvedStorageConnectionString, settings.ResolvedStorageConnectionString, StringComparison.OrdinalIgnoreCase)) + string.Equals(this.defaultProvider.Settings.StorageConnectionName, settings.StorageConnectionName, StringComparison.OrdinalIgnoreCase)) { return this.defaultProvider; } @@ -162,7 +162,7 @@ public DurabilityProvider GetDurabilityProvider(DurableClientAttribute attribute DurableClientAttribute key = new DurableClientAttribute() { TaskHub = settings.HubName, - ConnectionName = settings.ResolvedStorageConnectionString, + ConnectionName = settings.StorageConnectionName, }; return this.cachedProviders.GetOrAdd(key, _ => diff --git a/src/DurableTask.Netherite/OrchestrationService/NetheriteOrchestrationService.cs b/src/DurableTask.Netherite/OrchestrationService/NetheriteOrchestrationService.cs index 10badfdf..20437097 100644 --- a/src/DurableTask.Netherite/OrchestrationService/NetheriteOrchestrationService.cs +++ b/src/DurableTask.Netherite/OrchestrationService/NetheriteOrchestrationService.cs @@ -93,8 +93,8 @@ public NetheriteOrchestrationService(NetheriteOrchestrationServiceSettings setti TransportConnectionString.Parse(this.Settings.ResolvedTransportConnectionString, out this.configuredStorage, out this.configuredTransport); this.Logger = loggerFactory.CreateLogger(LoggerCategoryName); this.LoggerFactory = loggerFactory; - this.StorageAccountName = this.configuredTransport == TransportConnectionString.TransportChoices.Memory - ? this.Settings.ResolvedStorageConnectionString + this.StorageAccountName = this.configuredStorage == TransportConnectionString.StorageChoices.Memory + ? "Memory" : CloudStorageAccount.Parse(this.Settings.ResolvedStorageConnectionString).Credentials.AccountName; EtwSource.Log.OrchestrationServiceCreated(this.ServiceInstanceId, this.StorageAccountName, this.Settings.HubName, this.Settings.WorkerId, TraceUtils.AppName, TraceUtils.ExtensionVersion);