Put add_note behind version check

Author: WarmCyan

curifactory/experimental/artifact.py

@@ -4,6 +4,7 @@
 import hashlib
 import json
 import logging
+import sys
 import traceback
 from functools import partial
 from uuid import UUID
@@ -323,7 +324,8 @@ def get(self):
             # NOTE: stage handles running cachers
             return self.obj
         except Exception as e:
-            e.add_note(f"Was trying to retrieve artifact {self.name}")
+            if sys.version_info >= (3, 11, 0):
+                e.add_note(f"Was trying to retrieve artifact {self.name}")
             manager = cf.get_manager()
             stack_str = traceback.format_exc()
             manager.record_pipeline_failure(e, stack_str)

curifactory/experimental/caching.py

@@ -2,6 +2,7 @@
 import json
 import os
 import pickle
+import sys
 from pathlib import Path
 from typing import Any
 
@@ -508,7 +509,8 @@ def save_obj(self, relation_object: duckdb.DuckDBPyRelation):
             try:
                 db.sql(query)
             except duckdb.duckdb.ParserException as e:
-                e.add_note(f"Was trying to run query: {query}")
+                if sys.version_info >= (3, 11, 0):
+                    e.add_note(f"Was trying to run query: {query}")
                 raise
 
         # add a metadata row
@@ -552,7 +554,8 @@ def clear_obj(self):
             deletion_query = f"DELETE FROM {self.get_table_name()} USING ({self.get_table_name()} INNER JOIN _cftrack_{self.get_table_name()} ON {self.join_condition()}) AS delete_ref WHERE {self.equals_condition('delete_ref')}"
             db.sql(deletion_query)
         except Exception as e:
-            e.add_note(f"Was running query: {deletion_query}")
+            if sys.version_info >= (3, 11, 0):
+                e.add_note(f"Was running query: {deletion_query}")
             raise
 
         db.sql(
@@ -565,7 +568,8 @@ def load_obj(self):
         try:
             return db.sql(selection_query)
         except Exception as e:
-            e.add_note(f"Was running selection query: {selection_query}")
+            if sys.version_info >= (3, 11, 0):
+                e.add_note(f"Was running selection query: {selection_query}")
             raise
 
 

curifactory/experimental/stage.py

@@ -2,6 +2,7 @@
 import hashlib
 import inspect
 import os
+import sys
 import threading
 import time
 from collections.abc import Callable
@@ -938,7 +939,8 @@ def __call__(self):  # noqa: C901
             self.computed = True
             return returns
         except Exception as e:
-            e.add_note(f"Was trying to run stage {self.contextualized_name}")
+            if sys.version_info >= (3, 11, 0):
+                e.add_note(f"Was trying to run stage {self.contextualized_name}")
             raise
 
     def __repr__(self):