move modules to utils

Author: David Eigen

clarifai/client/model.py

@@ -24,8 +24,8 @@
                                       MAX_RANGE_SIZE, MIN_CHUNK_SIZE, MIN_RANGE_SIZE,
                                       MODEL_EXPORT_TIMEOUT, RANGE_SIZE, TRAINABLE_MODEL_TYPES)
 from clarifai.errors import UserError
-from clarifai.runners.utils import video_utils
 from clarifai.urls.helper import ClarifaiUrlHelper
+from clarifai.utils import video_utils
 from clarifai.utils.logging import logger
 from clarifai.utils.misc import BackoffIterator, status_is_retryable
 from clarifai.utils.model_train import (find_and_replace_key, params_parser,

clarifai/runners/models/base_typed_model.py

@@ -6,8 +6,8 @@
 from clarifai_grpc.grpc.api.service_pb2 import PostModelOutputsRequest
 from google.protobuf import json_format
 
-from clarifai.runners.utils.stream_utils import readahead
 from clarifai.runners.utils.url_fetcher import ensure_urls_downloaded
+from clarifai.utils.stream_utils import readahead
 
 from ..utils.data_handler import InputDataHandler, OutputDataHandler
 from .model_class import ModelClass

clarifai/runners/models/model_class.py

@@ -3,8 +3,8 @@
 
 from clarifai_grpc.grpc.api import service_pb2
 
-from clarifai.runners.utils.stream_utils import readahead
 from clarifai.runners.utils.url_fetcher import ensure_urls_downloaded
+from clarifai.utils.stream_utils import readahead
 
 
 class ModelClass(ABC):

clarifai/runners/utils/url_fetcher.py

@@ -3,8 +3,8 @@
 
 import fsspec
 
-from clarifai.runners.utils.stream_utils import MB
 from clarifai.utils.logging import logger
+from clarifai.utils.stream_utils import MB
 
 
 def download_input(input):

clarifai/runners/utils/stream_utils.py renamed to clarifai/utils/stream_utils.py

@@ -5,7 +5,7 @@
 
 import requests
 
-from clarifai.runners.utils import stream_utils
+from clarifai.utils import stream_utils
 from clarifai.utils.misc import optional_import
 
 av = optional_import("av", pip_package="av")

clarifai/runners/utils/video_utils.py renamed to clarifai/utils/video_utils.py

@@ -1,8 +1,7 @@
 import io
 import unittest
 
-from clarifai.runners.utils.stream_utils import (SeekableStreamingChunksReader,
-                                                 StreamingChunksReader)
+from clarifai.utils.stream_utils import SeekableStreamingChunksReader, StreamingChunksReader
 
 
 class TestStreamingChunksReader(unittest.TestCase):