in test-harness/terratest-extensions/modules/azure/datafactory.go [127:149]
func listPipelinesByDataFactoryE(subscriptionID string, resourceGroupName string, dataFactoryName string) (*[]datafactory.PipelineResource, error) {
pClient, err := pipelineClientE(subscriptionID)
if err != nil {
return nil, err
}
iteratorPipelines, err := pClient.ListByFactoryComplete(context.Background(), resourceGroupName, dataFactoryName)
if err != nil {
return nil, err
}
pipelinesList := make([]datafactory.PipelineResource, 0)
for iteratorPipelines.NotDone() {
pipelinesList = append(pipelinesList, iteratorPipelines.Value())
err = iteratorPipelines.Next()
if err != nil {
return nil, err
}
}
return &pipelinesList, err
}