Fix: arguments

Author: heptaflar

kaleidoscope/processor.py

@@ -75,8 +75,8 @@ def run(self, args: Namespace):  # noqa: D102
             writer: Writing = self._create_writer(args)
 
             # open the source file
-            get_logger().debug(f"opening source dataset: {args.source_id}")
-            source = reader.read(args.source_id, depth_level=args.depth_level)
+            get_logger().debug(f"opening source dataset: {args.target_file}")
+            source = reader.read(args.target_file, depth_level=args.depth_level)
 
             # create the processing graph
             get_logger().info("starting creating processing graph")
@@ -85,9 +85,9 @@ def run(self, args: Namespace):  # noqa: D102
 
             # write the target file
             get_logger().info(
-                f"starting writing target dataset: {args.target_id}"
+                f"starting writing target dataset: {args.target_file}"
             )
-            writer.write(target, args.target_id)
+            writer.write(target, args.target_file)
             get_logger().info("finished writing target dataset")
         finally:
             get_logger().info("starting closing datasets")

kaleidoscope/runner.py

@@ -29,9 +29,8 @@ class Runner:
     Runs a processor.
 
     Takes care of parsing command line arguments, setting up the logger,
-    configuring Dask, running (and optionally profiling) the processor,
-    handling exceptions, terminating Dask, and calling system exit with
-    an exit code.
+    configuring Dask, and running the processor, handling exceptions,
+    terminating Dask, and calling system exit with an exit code.
     """
 
     _parser: ArgumentParser
@@ -143,8 +142,6 @@ def _init_dask(args):
         get_logger().debug("starting initializing Dask")
         # noinspection PyTestUnpassedFixture
         dask.config.set({"temporary-directory": args.tmpdir})
-        if args.prof is not None:
-            args.mode = "synchronous"
         match args.mode:
             case "synchronous":
                 dask.config.set(scheduler="synchronous")