Method initialize_services

lightx2v/server/api/server.py:159–162

(self, cache_dir: Path, inference_service: DistributedInferenceService)

        except Exception as e:
            logger.exception(f"Task {task_id} processing failed: {str(e)}")
            original_et = getattr(e, "original_error_type", "") or ""
            task_manager.fail_task(task_id, str(e), error_type=original_et or None)
        finally:
            if lock_acquired:
                task_manager.release_processing_lock(task_id)

    def initialize_services(self, cache_dir: Path, inference_service: DistributedInferenceService):