Fixup

Signed-off-by: Matthew Ballance <[email protected]>

src/dv_flow/mgr/task_graph_builder.py

@@ -22,11 +22,11 @@ def __post_init__(self):
         if self.pkg_rgy is None:
             self.pkg_rgy = PkgRgy.inst()
 
-        self._pkg_spec_s.append(self.root_pkg)
-        pkg = self.root_pkg.mkPackage(self)
-        self._pkg_spec_s.pop()
-        self._pkg_m[PackageSpec(self.root_pkg.name)] = pkg
-        print("pkg_m: %s" % self.root_pkg.name)
+        if self.root_pkg is not None:
+            self._pkg_spec_s.append(self.root_pkg)
+            pkg = self.root_pkg.mkPackage(self)
+            self._pkg_spec_s.pop()
+            self._pkg_m[PackageSpec(self.root_pkg.name)] = pkg
 
     def push_package(self, pkg : Package):
         self._pkg_s.append(pkg)
@@ -157,6 +157,7 @@ def getPackage(self, spec : PackageSpec) -> Package:
                             break
 
             if pkg is None:
+                print("Checking registry")
                 p_def =  self.pkg_rgy.getPackage(spec.name)
 
                 if p_def is not None:

src/dv_flow/mgr/task_graph_runner_local.py

@@ -54,7 +54,7 @@ def __post_init__(self):
 
 
     async def exec(self, *args, **kwargs):
-        return self.create_subprocess(*args, **kwargs)
+        return await self.create_subprocess(*args, **kwargs)
 
     async def run(self, task : Union[Task,List[Task]]) -> List['TaskData']:
         if isinstance(task, Task):