(entry nestedImportEntry, item importQueueItem, baseDir string, cache *ImportCache, workflowFilePath string, yamlContent string, state *importBFSState)
| 391 | } |
| 392 | |
| 393 | func enqueueNestedImportEntry(entry nestedImportEntry, item importQueueItem, baseDir string, cache *ImportCache, workflowFilePath string, yamlContent string, state *importBFSState) error { |
| 394 | nestedImportPath := entry.path |
| 395 | nestedFilePath, nestedSectionName := splitImportPathAndSection(nestedImportPath) |
| 396 | resolvedPath, nestedRemoteOrigin, err := resolveNestedImportPathAndOrigin(item, nestedFilePath) |
| 397 | if err != nil { |
| 398 | return err |
| 399 | } |
| 400 | nestedBaseDir := determineNestedBaseDir(item, resolvedPath, baseDir) |
| 401 | nestedFullPath, err := ResolveIncludePath(resolvedPath, nestedBaseDir, cache) |
| 402 | if err != nil { |
| 403 | return formatNestedResolveError(nestedImportPath, nestedFilePath, item, workflowFilePath, yamlContent, err) |
| 404 | } |
| 405 | canonicalImportPath := canonicalizeNestedImportPath(nestedImportPath, nestedBaseDir, baseDir, nestedRemoteOrigin, nestedFullPath) |
| 406 | return enqueueNestedVisitedPath(state, canonicalImportPath, nestedFullPath, nestedSectionName, baseDir, entry.inputs, nestedRemoteOrigin) |
| 407 | } |
| 408 | |
| 409 | func resolveNestedImportPathAndOrigin(item importQueueItem, nestedFilePath string) (string, *remoteImportOrigin, error) { |
| 410 | if item.remoteOrigin != nil && !isWorkflowSpec(nestedFilePath) { |
no test coverage detected