run: Support unmanaged pathogen repositories with local paths

CHANGES.md

@@ -39,6 +39,15 @@ supported Python version is always bundled with `nextstrain`.
   Batch job.
   ([#460](https://github.com/nextstrain/cli/pull/460))
 
+* `nextstrain run` now supports an alternative invocation where a path to a
+  local directory that is a pathogen repository can be given instead of a
+  pathogen name (and optionally version).  This allows `nextstrain run` to be
+  used with pathogen repos managed outside of Nextstrain CLI (i.e. not by
+  `nextstrain setup` and `nextstrain update`), which can be useful for the
+  analysis directory support and local testing.  The workflow to run is still
+  given separately by name (not path).
+  ([#476](https://github.com/nextstrain/cli/issues/476))
+
 ## Bug fixes
 
 * `nextstrain setup <pathogen>@<version>` and `nextstrain update <pathogen>@<version>`

doc/changes.md

@@ -43,6 +43,15 @@ supported Python version is always bundled with `nextstrain`.
   Batch job.
   ([#460](https://github.com/nextstrain/cli/pull/460))
 
+* `nextstrain run` now supports an alternative invocation where a path to a
+  local directory that is a pathogen repository can be given instead of a
+  pathogen name (and optionally version).  This allows `nextstrain run` to be
+  used with pathogen repos managed outside of Nextstrain CLI (i.e. not by
+  `nextstrain setup` and `nextstrain update`), which can be useful for the
+  analysis directory support and local testing.  The workflow to run is still
+  given separately by name (not path).
+  ([#476](https://github.com/nextstrain/cli/issues/476))
+
 (v-next-bug-fixes)=
 ### Bug fixes
 

doc/commands/run.rst

@@ -12,7 +12,7 @@ nextstrain run
 
 .. code-block:: none
 
-    usage: nextstrain run [options] <pathogen-name>[@<version>] <workflow-name> <analysis-directory> [<target> [<target> [...]]]
+    usage: nextstrain run [options] <pathogen-name>[@<version>]|<pathogen-path> <workflow-name> <analysis-directory> [<target> [<target> [...]]]
            nextstrain run --help
 
 
@@ -44,12 +44,17 @@ positional arguments
 
 
 
-.. option:: <pathogen-name>[@<version>]
+.. option:: <pathogen-name>[@<version>]|<pathogen-path>
 
     The name (and optionally, version) of a previously set up pathogen.
     See :command-reference:`nextstrain setup`.  If no version is
     specified, then the default version (if any) will be used.
 
+    Alternatively, the local path to a directory that is a pathogen
+    repository.  For this case to be recognized as such, the path must
+    contain a separator (/) or consist entirely of the current
+    directory (.) or parent directory (..) specifier.
+
     Required.
 
 .. option:: <workflow-name>

nextstrain/cli/command/run.py

@@ -23,14 +23,15 @@
 manage the run and download results after completion.
 """
 
+import os.path
 from inspect import cleandoc
 from shlex import quote as shquote
 from textwrap import dedent
 from .. import runner
 from ..argparse import add_extended_help_flags, MkDirectoryPath, SKIP_AUTO_DEFAULT_IN_HELP
-from ..debug import DEBUGGING
+from ..debug import DEBUGGING, debug
 from ..errors import UserError
-from ..pathogens import PathogenVersion
+from ..pathogens import PathogenVersion, UnmanagedPathogen
 from ..runner import aws_batch, docker, singularity
 from ..util import byte_quantity, split_image_name
 from ..volume import NamedVolume
@@ -39,7 +40,7 @@
 
 def register_parser(subparser):
     """
-    %(prog)s [options] <pathogen-name>[@<version>] <workflow-name> <analysis-directory> [<target> [<target> [...]]]
+    %(prog)s [options] <pathogen-name>[@<version>]|<pathogen-path> <workflow-name> <analysis-directory> [<target> [<target> [...]]]
     %(prog)s --help
     """
 
@@ -48,14 +49,19 @@ def register_parser(subparser):
     # Positional parameters
     parser.add_argument(
         "pathogen",
-        metavar = "<pathogen-name>[@<version>]",
+        metavar = "<pathogen-name>[@<version>]|<pathogen-path>",
         help    = cleandoc(f"""
             The name (and optionally, version) of a previously set up pathogen.
             See :command-reference:`nextstrain setup`.  If no version is
             specified, then the default version (if any) will be used.
 
+            Alternatively, the local path to a directory that is a pathogen
+            repository.  For this case to be recognized as such, the path must
+            contain a separator ({{path_sep}}) or consist entirely of the current
+            directory ({os.path.curdir}) or parent directory ({os.path.pardir}) specifier.
+
             Required.
-            """))
+            """.format(path_sep = " or ".join(sorted(set([os.path.sep, os.path.altsep or os.path.sep]))))))
 
     parser.add_argument(
         "workflow",
@@ -226,21 +232,32 @@ def run(opts):
             """)
 
     # Resolve pathogen and workflow names to a local workflow directory.
-    pathogen = PathogenVersion(opts.pathogen)
+    try:
+        pathogen = UnmanagedPathogen(opts.pathogen)
+    except ValueError:
+        debug(f"Treating {opts.pathogen!r} as managed pathogen version")
+        pathogen = PathogenVersion(opts.pathogen)
+    else:
+        debug(f"Treating {opts.pathogen!r} as unmanaged pathogen directory")
 
     if opts.workflow not in pathogen.registered_workflows():
         print(f"The {opts.workflow!r} workflow is not registered as a compatible workflow, but trying to run anyways.")
 
     workflow_directory = pathogen.workflow_path(opts.workflow)
 
     if not workflow_directory.is_dir() or not (workflow_directory / "Snakefile").is_file():
-        raise UserError(f"""
-            No {opts.workflow!r} workflow for pathogen {opts.pathogen!r} found {f"in {str(workflow_directory)!r}" if DEBUGGING else "locally"}.
-
-            Maybe you need to update to a newer version of the pathogen?
-
-            Hint: to update the pathogen, run `nextstrain update {shquote(pathogen.name)}`.
-            """)
+        if isinstance(pathogen, UnmanagedPathogen):
+            raise UserError(f"""
+                No {opts.workflow!r} workflow for pathogen {opts.pathogen!r} found {f"in {str(workflow_directory)!r}" if DEBUGGING else "locally"}.
+                """)
+        else:
+            raise UserError(f"""
+                No {opts.workflow!r} workflow for pathogen {opts.pathogen!r} found {f"in {str(workflow_directory)!r}" if DEBUGGING else "locally"}.
+
+                Maybe you need to update to a newer version of the pathogen?
+
+                Hint: to update the pathogen, run `nextstrain update {shquote(pathogen.name)}`.
+                """)
 
     # The pathogen volume is the pathogen directory (i.e. repo).
     # The workflow volume is the workflow directory within the pathogen directory.

nextstrain/cli/pathogens.py

@@ -642,6 +642,46 @@ def __eq__(self, other) -> bool:
            and (self.url    == other.url or self.url is None or other.url is None)
 
 
+class UnmanagedPathogen:
+    """
+    A local directory that's a pathogen repo, not managed by Nextstrain CLI.
+
+    Used by ``nextstrain run``.  Includes only the :cls:`PathogenVersion` API
+    surface that ``nextstrain run`` requires.
+    """
+    path: Path
+    registration_path: Path
+
+    registration: Optional[dict] = None
+
+    def __init__(self, path: str):
+        spec = PathogenSpec.parse(path)
+
+        if not spec.name or (spec.name not in set([os.path.curdir, os.path.pardir]) and not (set(spec.name) & set([os.path.sep, os.path.altsep or os.path.sep]))):
+            raise ValueError(f"the {spec.name!r} part of {path!r} does not look like a path")
+
+        self.path = Path(path)
+
+        if not self.path.is_dir():
+            raise UserError(f"""
+                Path {str(self.path)!r} is not a directory (or does not exist).
+                """)
+
+        self.registration_path = self.path / "nextstrain-pathogen.yaml"
+
+        if self.registration_path.exists():
+            self.registration = read_pathogen_registration(self.registration_path)
+
+    registered_workflows = PathogenVersion.registered_workflows
+    workflow_path = PathogenVersion.workflow_path
+
+    def __str__(self) -> str:
+        return str(self.path)
+
+    def __repr__(self) -> str:
+        return f"<UnmanagedPathogen path={str(self.path)!r}>"
+
+
 def every_pathogen_default_by_name(pathogens: Dict[str, Dict[str, PathogenVersion]] = None) -> Dict[str, PathogenVersion]:
     """
     Scans file system to return a dict of :cls:`PathogenVersion` objects,