csvpath
diff --git a/‎csvpath/managers/integrations/ol/v2/sender.py‎
Lines changed: 5 additions & 0 deletions b/‎csvpath/managers/integrations/ol/v2/sender.py‎
Lines changed: 5 additions & 0 deletions
diff --git a/‎csvpath/managers/paths/paths_registrar.py‎
Lines changed: 6 additions & 1 deletion b/‎csvpath/managers/paths/paths_registrar.py‎
Lines changed: 6 additions & 1 deletion
diff --git a/‎csvpath/managers/registrar.py‎
Lines changed: 13 additions & 0 deletions b/‎csvpath/managers/registrar.py‎
Lines changed: 13 additions & 0 deletions
diff --git a/‎tests/csvpaths/examples/csvpaths_examples_openlineage/test_csvpaths_examples_openlineage.py‎
Lines changed: 4 additions & 0 deletions b/‎tests/csvpaths/examples/csvpaths_examples_openlineage/test_csvpaths_examples_openlineage.py‎
Lines changed: 4 additions & 0 deletions
@@ -33,6 +33,11 @@ def client(self):
         return self._client
 
     def metadata_update(self, mdata: Metadata) -> None:
+        if not hasattr(self, "csvpaths"):
+            self.config.logger.warning(
+                "No CsvPaths available. OpenLineage only works with CsvPaths instances."
+            )
+            return
         es = EventBuilder(listener=self).build(mdata)
         for e in es:
             self.client.emit(e)
@@ -67,14 +67,19 @@ def update_manifest_if(self, *, group_file_path, name, paths):
             mdata.manifest_path = mpath
             mdata.fingerprint = f
             self.distribute_update(mdata)
-        else:
+        elif self.csvpaths:
             #
             # leave as info so nobody has to dig to see why no update
             #
             self.csvpaths.logger.info(
                 "Fingerprints of named-paths %s match, as expected; no need to fire update event",
                 name,
             )
+        else:
+            #
+            # no logger is not helpful or expected
+            #
+            print("WARNING: PathsRegistrar has no CsvPaths instance")
 
     def metadata_update(self, mdata: Metadata) -> None:
         jdata = self.get_manifest(mdata.manifest_path)
 
@@ -66,6 +66,19 @@ def distribute_update(self, mdata: Metadata) -> None:
                 self.csvpaths.logger.debug(
                     "Updating listener %s with metadata %s", lst, mdata
                 )
+                #
+                # this is important. is this the best place to do it?
+                #
+                lst.csvpaths = self.csvpaths
+            else:
+                if self.result and self.result.csvpath:
+                    self.result.csvpath.logger.warn("No csvpaths on Registrar")
+                else:
+                    #
+                    # no result and no csvpath likely just means we are in a
+                    # CsvPath only context.
+                    #
+                    ...
             try:
                 lst.metadata_update(mdata)
             except Exception as ex:
 
@@ -190,6 +190,10 @@ def test_csvpaths_openlineage_results_1(self) -> None:
 
     def test_csvpaths_openlineage_result_1(self) -> None:
         paths = CsvPaths()
+
+        paths.config.set(section="listeners", name="groups", value="openlineage")
+        paths.config.set(section="listeners", name="openlineage.version", value="2")
+
         ref, mdata = paths.file_manager.add_named_file(
             name="orders", path=FILE, return_metadata=True
         )