Add debug flag to cf ls

Author: WarmCyan

curifactory/experimental/cli.py

@@ -3,6 +3,7 @@
 # https://stackoverflow.com/questions/4042452/display-help-message-with-python-argparse-when-script-is-called-without-any-argu
 
 import argparse
+import json
 import logging
 import os
 from dataclasses import MISSING, fields
@@ -33,6 +34,11 @@ def main():  # noqa: C901
 
     subparsers = parser.add_subparsers(help="Commands:", dest="command")
 
+    conf_parser = subparsers.add_parser(
+        "config", help="View/edit curifactory configuration"
+    )
+    conf_parser.add_argument("--debug", "--verbose", action="store_true", dest="debug")
+
     ls_parser = subparsers.add_parser("ls", help="List pipelines")
     ls_parser.add_argument("thing_to_list", nargs="?")
     ls_parser.add_argument(
@@ -45,6 +51,7 @@ def main():  # noqa: C901
     ls_parser.add_argument(
         "--paths", dest="list_paths", action="store_true", help="List artifact paths"
     )
+    ls_parser.add_argument("--debug", "--verbose", action="store_true", dest="debug")
 
     run_parser = subparsers.add_parser("run", help="Run an pipeline", add_help=False)
     run_parser.add_argument("pipeline").completer = completer_pipeline
@@ -338,6 +345,10 @@ def list_converter(string):
     #         import subprocess
     #         subprocess.run(["/usr/bin/kitty", "icat"], input=dot.pipe(format="kitty"))
 
+    elif parsed.command == "config":
+        manager = cf.get_manager()
+        print(json.dumps(manager.config, indent=4))
+
     elif parsed.command == "map":
         manager = cf.get_manager()
         manager.load_default_pipeline_imports()
@@ -498,6 +509,11 @@ def list_converter(string):
 
     elif parsed.command == "ls":
         manager = cf.get_manager()
+        if parsed.debug:
+            print("Yep it's debug")
+            # logging.getLogger("curifactory").setLevel(logging.DEBUG)
+            manager.logger.setLevel(logging.DEBUG)
+            manager.init_root_logging()
 
         if not parsed.list_runs:
             manager.load_default_pipeline_imports()
@@ -551,7 +567,7 @@ def list_converter(string):
                 else:
                     print(
                         artifact.name.ljust(20),
-                        f"".ljust(40),
+                        "".ljust(40),
                         f"(context: {artifact.context_name})".ljust(40),
                     )
         else:

curifactory/experimental/manager.py

@@ -310,6 +310,7 @@ def load_default_pipeline_imports(self):
 
     def import_pipelines_from_module(self, module_str: str):
         # try to load the module
+        self.logger.debug(f"Attempting to import {module_str}")
         module = self.quietly_import_module(module_str)
         remainder = None
         while module is None:
@@ -363,6 +364,9 @@ def add_pipeline_to_ref_names(self, module_str: str, attr_name: str, pipeline):
             building_module_str = ".".join(module_pieces[-i:])
             self.pipeline_ref_names[f"{building_module_str}.{attr_name}"] = pipeline
             self.pipeline_ref_names[f"{building_module_str}.{pipeline.name}"] = pipeline
+            self.logger.debug(
+                f"Adding pipeline {pipeline.name} at {building_module_str}.{pipeline.name}"
+            )
 
     def divide_reference_parts(self, ref_str: str) -> dict[str, str]:
         parts = {"module": None, "pipeline": None, "artifact_filter": None}