in ProcessManager/CacheManager/CacheConnectorUpsert.cs [220:232]
private static async Task<bool> PublishEvent(APITask task, string taskBody, AppInsightsLogger appInsightsLogger)
{
var eventGridTopicUri = Environment.GetEnvironmentVariable(EVENT_GRID_TOPIC_URI_VARIABLE_NAME, EnvironmentVariableTarget.Process);
var eventGridKey = Environment.GetEnvironmentVariable(EVENT_GRID_KEY_VARIABLE_NAME, EnvironmentVariableTarget.Process);
if (string.IsNullOrEmpty(eventGridTopicUri) || string.IsNullOrEmpty(eventGridKey))
{
return await PublishServiceBusQueueEvent(task, taskBody, appInsightsLogger);
}
else
{
return await PublishEventGridEvent(task, taskBody, eventGridTopicUri, eventGridKey, appInsightsLogger);
}
}