fix: harden error handling and add missing future annotations

Error handling:
- Protect ast.parse() in _normalizer.py (returns original on SyntaxError)
- Protect cst.parse_module() in _replacement.py (raises ValueError)
- Narrow except Exception to OSError/SyntaxError in _discovery.py (2 sites)
- Narrow except Exception to sqlite3.Error/OSError in _data_parsers.py
- Narrow pickle except to specific unpickling errors in _data_parsers.py

Missing future annotations:
- Add from __future__ import annotations to 12 __init__.py files

packages/codeflash-core/src/codeflash_core/danom/__init__.py

@@ -1,5 +1,7 @@
 """Functional programming utilities: Result, Stream, compose, and more."""
 
+from __future__ import annotations
+
 from .new_type import new_type
 from .result import Err, Ok, Result
 from .safe import safe, safe_method

packages/codeflash-python/src/codeflash_python/ai/__init__.py

@@ -1,5 +1,7 @@
 """AI service wrappers for refinement and repair."""
 
+from __future__ import annotations
+
 from ._refinement import (
     AdaptiveCandidate,
     AdaptiveOptimizeRequest,

packages/codeflash-python/src/codeflash_python/analysis/__init__.py

@@ -1,5 +1,7 @@
 """Code analysis, discovery, and function ranking."""
 
+from __future__ import annotations
+
 from ._code_utils import find_preexisting_objects
 from ._discovery import discover_functions
 from ._extraction import extract_function_source

packages/codeflash-python/src/codeflash_python/analysis/_discovery.py

@@ -253,10 +253,15 @@ def inspect_top_level_functions_or_methods(
     line_no: int | None = None,
 ) -> FunctionProperties | None:
     """Inspect whether a function/method is top-level in *file_name*."""
-    with file_name.open(encoding="utf8") as file:
     try:
-            ast_module = ast.parse(file.read())
-        except Exception:  # noqa: BLE001
+        source = file_name.read_text(encoding="utf-8")
+    except OSError:
+        log.warning("Failed to read %s", file_name)
+        return None
+    try:
+        ast_module = ast.parse(source)
+    except SyntaxError:
+        log.debug("Failed to parse %s", file_name)
         return None
     visitor = TopLevelFunctionOrMethodVisitor(
         file_name=file_name,
@@ -317,8 +322,12 @@ def find_all_functions_in_file(
     """Find all optimizable functions in a Python file."""
     try:
         source = file_path.read_text(encoding="utf-8")
+    except OSError:
+        log.warning("Failed to read %s", file_path)
+        return {}
+    try:
         ast.parse(source, filename=str(file_path))
-    except Exception:  # noqa: BLE001
+    except SyntaxError:
         log.debug("Failed to parse %s", file_path)
         return {}
     fns = discover_functions(source, file_path)

packages/codeflash-python/src/codeflash_python/analysis/_normalizer.py

@@ -190,7 +190,10 @@ def normalize_python_code(code: str, remove_docstrings: bool = True) -> str:  #
     Replaces local variable names with canonical forms (var_0, var_1, etc.)
     while preserving function names, class names, parameters, and imports.
     """
+    try:
         tree = ast.parse(code)
+    except SyntaxError:
+        return code
 
     if remove_docstrings:
         _remove_docstrings_from_ast(tree)

packages/codeflash-python/src/codeflash_python/api/__init__.py

@@ -1,5 +1,7 @@
 """Public programmatic API for codeflash-python."""
 
+from __future__ import annotations
+
 from ._config import OptimizationConfig
 from ._session import OptimizationSession, optimize_function
 

packages/codeflash-python/src/codeflash_python/benchmarking/__init__.py

@@ -1,5 +1,7 @@
 """Benchmark tracing and profiling models."""
 
+from __future__ import annotations
+
 from .models import BenchmarkKey, ConcurrencyMetrics, ProcessedBenchmarkInfo
 
 __all__ = [

packages/codeflash-python/src/codeflash_python/codegen/__init__.py

@@ -1,5 +1,7 @@
 """Code generation and source replacement."""
 
+from __future__ import annotations
+
 from ..analysis._code_utils import find_preexisting_objects
 from ._replacement import (
     replace_function_source,

packages/codeflash-python/src/codeflash_python/codegen/_replacement.py

@@ -120,16 +120,24 @@ def replace_function_source(
     class_name = function.class_name
     func_name = function.function_name
 
+    try:
         optimized_func = _find_function(
             cst.parse_module(new_source),
             class_name,
             func_name,
         )
+    except cst.ParserSyntaxError:
+        msg = f"Failed to parse new_source for {function.qualified_name!r}"
+        raise ValueError(msg) from None
     if optimized_func is None:
         msg = f"Function {function.qualified_name!r} not found in new_source"
         raise ValueError(msg)
 
+    try:
         original = cst.parse_module(source)
+    except cst.ParserSyntaxError:
+        msg = f"Failed to parse source for {function.qualified_name!r}"
+        raise ValueError(msg) from None
     new_body: list[cst.BaseStatement] = []
 
     for node in original.body:

packages/codeflash-python/src/codeflash_python/context/__init__.py

@@ -1,5 +1,7 @@
 """Context extraction for function optimization."""
 
+from __future__ import annotations
+
 from .helpers import discover_helpers
 from .models import (
     CodeContextType,

packages/codeflash-python/src/codeflash_python/runtime/__init__.py

@@ -1 +1,3 @@
 """Runtime decorators and utilities."""
+
+from __future__ import annotations

packages/codeflash-python/src/codeflash_python/runtime/_picklepatch/__init__.py

@@ -1 +1,3 @@
 """Pickle patching utilities for handling unpicklable objects."""
+
+from __future__ import annotations

packages/codeflash-python/src/codeflash_python/test_discovery/__init__.py

@@ -1,5 +1,7 @@
 """Test discovery, file-level filtering, and Jedi-based linking."""
 
+from __future__ import annotations
+
 from .discovery import (
     discover_tests_pytest,
     discover_unit_tests,

packages/codeflash-python/src/codeflash_python/testing/__init__.py

@@ -1,5 +1,7 @@
 """Test execution infrastructure."""
 
+from __future__ import annotations
+
 from ._parse_results import parse_test_results
 from ._test_runner import (
     async_run_behavioral_tests,

packages/codeflash-python/src/codeflash_python/testing/_data_parsers.py

@@ -45,15 +45,22 @@ def parse_sqlite_test_results(
             " return_value, verification_type"
             " FROM test_results"
         ).fetchall()
-    except Exception:  # noqa: BLE001
+    except sqlite3.Error:
         log.warning(
-            "Failed to parse test results from %s.",
+            "Failed to read test results from %s.",
             sqlite_file_path,
             exc_info=True,
         )
         if db is not None:
             db.close()
         return test_results
+    except OSError:
+        log.warning(
+            "Failed to open %s.",
+            sqlite_file_path,
+            exc_info=True,
+        )
+        return test_results
     finally:
         if db is not None:
             db.close()
@@ -125,8 +132,8 @@ def _process_sqlite_row_inner(
 
         try:
             ret_val = (pickle.loads(val[7]),)  # noqa: S301
-        except Exception:  # noqa: BLE001
-            log.debug(
+        except (pickle.UnpicklingError, EOFError, ValueError, TypeError):
+            log.warning(
                 "Failed to deserialize return value for %s",
                 test_function_name,
                 exc_info=True,

packages/codeflash-python/src/codeflash_python/verification/__init__.py

@@ -1,5 +1,7 @@
 """Behavioral verification and optimization results."""
 
+from __future__ import annotations
+
 from ._baseline import establish_original_code_baseline
 from ._verification import compare_test_results
 from .models import (