Remove debug lock-finding code from orchestrator

The _find_locks() function and related debug diagnostics were causing
isinstance() errors when traversing complex objects. This code was only
used for debugging pickle issues and is not needed in production.

Fixes CI failures with omero tests where the lock detection was
recursively traversing module internals and failing on type checks.

Author: trissim

external/pyqt-reactive

@@ -50,54 +50,6 @@
     resolve_lazy_configurations_for_serialization,
 )
 from openhcs.microscopes import create_microscope_handler
-
-
-def _find_locks(obj, path="", seen=None):
-    """Recursively find threading locks in an object."""
-    import threading
-
-    # Get lock types once
-    lock_types = (
-        threading.Lock,
-        threading.RLock,
-        threading.Semaphore,
-        threading.BoundedSemaphore,
-        threading.Condition,
-    )
-
-    if seen is None:
-        seen = set()
-
-    if id(obj) in seen:
-        return []
-    seen.add(id(obj))
-
-    locks = []
-
-    # Check if it's a lock
-    try:
-        if isinstance(obj, lock_types):
-            locks.append((path, type(obj).__name__))
-    except TypeError as e:
-        logger.warning(f"isinstance check failed for {path}: {e}")
-
-    # Recursively check containers
-    try:
-        if isinstance(obj, dict):
-            for key, val in obj.items():
-                locks.extend(_find_locks(val, f"{path}[{repr(key)}]", seen))
-        elif isinstance(obj, (list, tuple)):
-            for idx, val in enumerate(obj):
-                locks.extend(_find_locks(val, f"{path}[{idx}]", seen))
-        elif hasattr(obj, "__dict__"):
-            for attr_name, val in obj.__dict__.items():
-                locks.extend(_find_locks(val, f"{path}.{attr_name}", seen))
-    except (TypeError, AttributeError):
-        pass
-
-    return locks
-
-
 from openhcs.microscopes.microscope_base import MicroscopeHandler
 from openhcs.processing.backends.analysis.consolidate_analysis_results import (
     consolidate_results_directories,
@@ -1413,53 +1365,6 @@ def execute_compiled_plate(
                             continue
                         owned_wells = list(worker_assignments[worker_slot])
 
-                        # DEBUG: Check what's being pickled for locks
-                        logger.info(f"DEBUG: Submitting worker {worker_slot}")
-                        logger.info(
-                            f"DEBUG: pipeline_definition has {len(pipeline_definition)} steps"
-                        )
-
-                        # Check pipeline_definition for locks
-                        pd_locks = _find_locks(
-                            pipeline_definition, "pipeline_definition"
-                        )
-                        if pd_locks:
-                            logger.error(f"🔒 LOCKS IN pipeline_definition: {pd_locks}")
-                        else:
-                            logger.info(f"DEBUG: pipeline_definition is pickle-safe")
-
-                        # Check lane_contexts for locks
-                        lc_locks = _find_locks(lane_contexts, "lane_contexts")
-                        if lc_locks:
-                            logger.error(f"🔒 LOCKS IN lane_contexts: {lc_locks}")
-                        else:
-                            logger.info(f"DEBUG: lane_contexts is pickle-safe")
-
-                        for i, step in enumerate(pipeline_definition):
-                            func_attr = getattr(step, "func", None)
-                            logger.info(
-                                f"DEBUG: step[{i}].func = {type(func_attr).__name__ if func_attr else 'None'}"
-                            )
-                        logger.info(
-                            f"DEBUG: lane_contexts has {len(lane_contexts)} axes"
-                        )
-                        for axis_id, axis_contexts in lane_contexts:
-                            logger.info(
-                                f"DEBUG: axis {axis_id} has {len(axis_contexts)} contexts"
-                            )
-                            for ctx_key, ctx in axis_contexts[
-                                :1
-                            ]:  # Just check first context
-                                if hasattr(ctx, "step_plans"):
-                                    for step_idx, plan in list(ctx.step_plans.items())[
-                                        :2
-                                    ]:  # Just check first 2
-                                        if "func" in plan:
-                                            func_val = plan["func"]
-                                            logger.info(
-                                                f"DEBUG: context step_plans[{step_idx}]['func'] = {type(func_val).__name__}"
-                                            )
-
                         try:
                             future = executor.submit(
                                 _execute_worker_lane_static,