feat(LAB-3512): remove video processing parameters checks for SDK (#1872)

Co-authored-by: paulruelle <[email protected]>

Author: RuellePaul

src/kili/services/asset_import/video.py

@@ -4,7 +4,6 @@
 from concurrent.futures import ThreadPoolExecutor
 from enum import Enum
 from itertools import repeat
-from json import JSONDecodeError
 from typing import List, Optional
 
 from kili.core.helpers import get_mime_type, is_url
@@ -168,101 +167,20 @@ def get_data_type(self, assets):
             return VideoDataType.HOSTED_FILE
         return VideoDataType.LOCAL_FILE
 
-    @staticmethod
-    def are_native_videos(assets) -> bool:
-        """Determine if assets should be imported asynchronously and cut into frames."""
-        should_use_native_video_array = []
-        for asset in assets:
-            # json_metadata stringification is done later on the call
-            json_metadata_ = asset.get("json_metadata")
-            if not json_metadata_:
-                return False
-
-            processing_parameters = json_metadata_.get("processingParameters")
-            if not processing_parameters:
-                return False
-
-            should_use_native_video_array.append(
-                processing_parameters.get("shouldUseNativeVideo", True)
-            )
-        if all(should_use_native_video_array):
-            return True
-        if all(not b for b in should_use_native_video_array):
-            return False
-        raise ImportValidationError(
-            """
-            Cannot upload videos to split into frames
-            and video to keep as native in the same time.
-            Please separate the assets into 2 calls
-            """
-        )
-
-    @staticmethod
-    def has_complete_processing_parameters(asset) -> bool:
-        """Determine if assets should be imported asynchronously and cut into frames."""
-        try:
-            # json_metadata stringification is done later on the call
-            json_metadata = asset.get("json_metadata")
-            if not json_metadata:
-                return False
-
-            processing_parameters = json_metadata.get("processingParameters")
-
-            if not processing_parameters:
-                return False
-
-            required_keys = [
-                "codec",
-                "delayDueToMinPts",
-                "framesPlayedPerSecond",
-                "numberOfFrames",
-                "startTime",
-            ]
-            required_types = [str, (int, float), (int, float), (int, float), (int, float)]
-
-            for key, required_type in zip(required_keys, required_types):
-                value = processing_parameters.get(key)
-                if value is None or not isinstance(value, required_type):
-                    return False
-
-            if not float(processing_parameters.get("numberOfFrames")).is_integer():
-                return False
-
-            return True
-        except JSONDecodeError:
-            return False
-
-    def videos_have_complete_processing_parameters(self, assets) -> bool:
-        """Determine if assets should be imported asynchronously and cut into frames."""
-        for asset in assets:
-            if not self.has_complete_processing_parameters(asset):
-                return False
-        return True
-
     def import_assets(self, assets: List[AssetLike], input_type: InputType):
         """Import video assets into Kili."""
         self._check_upload_is_allowed(assets)
         data_type = self.get_data_type(assets)
         assets = self.filter_duplicate_external_ids(assets)
         if data_type == VideoDataType.LOCAL_FILE:
             assets = self.filter_local_assets(assets, self.raise_error)
-            are_native_videos = self.are_native_videos(assets)
-            videos_have_complete_processing_parameters = (
-                self.videos_have_complete_processing_parameters(assets)
-            )
-            is_synchronous = are_native_videos and videos_have_complete_processing_parameters
-            batch_params = BatchParams(is_hosted=False, is_asynchronous=not is_synchronous)
+            batch_params = BatchParams(is_hosted=False, is_asynchronous=True)
             batch_importer = VideoContentBatchImporter(
                 self.kili, self.project_params, batch_params, self.pbar
             )
             batch_size = IMPORT_BATCH_SIZE
         elif data_type == VideoDataType.HOSTED_FILE:
-            are_native_videos = self.are_native_videos(assets)
-            videos_have_complete_processing_parameters = (
-                self.videos_have_complete_processing_parameters(assets)
-            )
-            is_synchronous = are_native_videos and videos_have_complete_processing_parameters
-            batch_params = BatchParams(is_hosted=True, is_asynchronous=not is_synchronous)
+            batch_params = BatchParams(is_hosted=True, is_asynchronous=True)
             batch_importer = VideoContentBatchImporter(
                 self.kili, self.project_params, batch_params, self.pbar
             )