Upload files with `vila-upload`.

auto_processor.py

@@ -18,8 +18,35 @@ from .media import Image, Video, extract_media
 from .mm_utils import process_image, process_images
 from .tokenizer_utils import tokenize_conversation
 
-
-def vila_pad_fn(input_ids_list, padding_value=0, target_len=None, padding_side="left"):
+def fetch_image_url_or_fpath(url_or_fpath):
+    if url_or_fpath.startswith("http") or url_or_fpath.startswith("https"):
+        import tempfile
+        import requests
+        
+        # Download the image to a temporary file
+        temp_dir = tempfile.mkdtemp()
+        temp_file = os.path.join(temp_dir, os.path.basename(url_or_fpath))
+        
+        response = requests.get(url_or_fpath, stream=True)
+        response.raise_for_status()
+        
+        with open(temp_file, "wb") as f:
+            for chunk in response.iter_content(chunk_size=8192):
+                f.write(chunk)
+                
+        return temp_file
+    elif url_or_fpath.startswith("file://"):
+        fpath = url_or_fpath.replace("file://", "")
+        assert osp.exists(fpath), f"File {fpath} does not exist"
+        return fpath
+    elif osp.exists(url_or_fpath):
+        assert osp.isfile(url_or_fpath), f"File {url_or_fpath} is not a file"
+        return url_or_fpath
+    else:
+        raise ValueError(f"Unsupported image path: {url_or_fpath}")
+    
+
+def __pad_fn(input_ids_list, padding_value=0, target_len=None, padding_side="left"):
     # tensor shape is (batch_size, seq_len)
     max_len = max([ids.shape[1] for ids in input_ids_list])
     if target_len is not None:
@@ -47,6 +74,8 @@ class VILAProcessorKwargs(ProcessingKwargs, total=False):
     }
 
 
+
+
 class VILAProcessor(ProcessorMixin):
     # attributes = ["image_processor", "tokenizer"]
     attributes = []
@@ -115,7 +144,7 @@ class VILAProcessor(ProcessorMixin):
         return BatchFeature(
             data={
                 # "input_ids": torch.nn.utils.rnn.pad_sequence(input_ids, batch_first=True, padding_value=self.pad_token_id),
-                "input_ids": vila_pad_fn(
+                "input_ids": __pad_fn(
                     input_ids,
                     padding_value=self.tokenizer.pad_token_id,
                     padding_side="left",
@@ -216,9 +245,17 @@ class VILAProcessor(ProcessorMixin):
                 vila_chat["from"] = "human"
                 for content in chat["content"]:
                     if content["type"] == "image":
-                        vila_chat["value"].append(Image(content["path"]))
+                        if "path" in content:
+                            # VILA style
+                            vila_chat["value"].append(Image(fetch_image_url_or_fpath(content["path"])))
+                        elif "image" in content:
+                            # Qwen style
+                            vila_chat["value"].append(Image(fetch_image_url_or_fpath(content["image"])))
+                        else:
+                            raise ValueError(f"Unsupported content type `image`: {content}, `image` and `path` are required")
                     elif content["type"] == "text":
                         vila_chat["value"].append(content["text"])
+                    # NOTE(ligeng): video supports are needed here
                     else:
                         raise ValueError(f"Unsupported content type: {content['type']}")
             elif chat["role"] == "assistant":
@@ -228,7 +265,6 @@ class VILAProcessor(ProcessorMixin):
                     vila_chat["value"].append(content["text"])
             vila_conv.append(vila_chat)
 
-        # return self(vila_conv)
         return vila_conv