public DataFactoryController(AppIdealContext db)
{
_db = db;
_client = CreateClientAsync().GetAwaiter().GetResult();
}
[HttpPost("TriggerPipelineOne")]
public async Task<IActionResult> TriggerPipelineOneAsync([FromBody] PipelineOneUserSettingsRequest request)
{
var userSettings = ConvertUserSettingsObjectToDictionary(request);
string pipelineOne = Environment.GetEnvironmentVariable(PIPELINEONENAME);
return await TriggerPipelineAsync(pipelineOne, PipelineStatusOptions.StartedPipelineOne, userSettings);
}
public DataFactoryController(AppIdealContext db)
{
_db = db;
_client = CreateClientAsync().GetAwaiter().GetResult();
}
[HttpPost("TriggerPipelineOne")]
public async Task<IActionResult> TriggerPipelineOneAsync([FromBody] PipelineOneUserSettingsRequest request)
{
var userSettings = ConvertUserSettingsObjectToDictionary(request);
string pipelineOne = Environment.GetEnvironmentVariable(PIPELINEONENAME);
return await TriggerPipelineAsync(pipelineOne, PipelineStatusOptions.StartedPipelineOne, userSettings);
}