fix: Secure torch model inits with global locks (#1884)
Signed-off-by: Christoph Auer <cau@zurich.ibm.com>
This commit is contained in:
parent
13865c06f5
commit
598c9c53d4
@ -1,3 +1,4 @@
|
||||
import threading
|
||||
from collections.abc import Iterable
|
||||
from pathlib import Path
|
||||
from typing import Optional, Type, Union
|
||||
@ -15,6 +16,9 @@ from docling.models.utils.hf_model_download import (
|
||||
)
|
||||
from docling.utils.accelerator_utils import decide_device
|
||||
|
||||
# Global lock for model initialization to prevent threading issues
|
||||
_model_init_lock = threading.Lock()
|
||||
|
||||
|
||||
class PictureDescriptionVlmModel(
|
||||
PictureDescriptionBaseModel, HuggingFaceModelDownloadMixin
|
||||
@ -57,17 +61,18 @@ class PictureDescriptionVlmModel(
|
||||
)
|
||||
|
||||
# Initialize processor and model
|
||||
self.processor = AutoProcessor.from_pretrained(artifacts_path)
|
||||
self.model = AutoModelForVision2Seq.from_pretrained(
|
||||
artifacts_path,
|
||||
torch_dtype=torch.bfloat16,
|
||||
_attn_implementation=(
|
||||
"flash_attention_2"
|
||||
if self.device.startswith("cuda")
|
||||
and accelerator_options.cuda_use_flash_attention2
|
||||
else "eager"
|
||||
),
|
||||
).to(self.device)
|
||||
with _model_init_lock:
|
||||
self.processor = AutoProcessor.from_pretrained(artifacts_path)
|
||||
self.model = AutoModelForVision2Seq.from_pretrained(
|
||||
artifacts_path,
|
||||
torch_dtype=torch.bfloat16,
|
||||
_attn_implementation=(
|
||||
"flash_attention_2"
|
||||
if self.device.startswith("cuda")
|
||||
and accelerator_options.cuda_use_flash_attention2
|
||||
else "eager"
|
||||
),
|
||||
).to(self.device)
|
||||
|
||||
self.provenance = f"{self.options.repo_id}"
|
||||
|
||||
|
Loading…
Reference in New Issue
Block a user