renamed modules

Author: Andrei Neagu

packages/aws-library/tests/test_s3_client.py

@@ -60,15 +60,15 @@
 )
 from pytest_simcore.helpers.typing_env import EnvVarsDict
 from servicelib.archiving_utils import unarchive_dir
-from servicelib.file_utils import remove_directory
-from servicelib.progress_bar import ProgressBarData
-from servicelib.utils import limited_as_completed, limited_gather
-from servicelib.zip_stream import (
+from servicelib.data_streams import (
     ArchiveEntries,
     DiskStreamReader,
-    get_zip_archive_file_stream,
+    get_zip_data_stream,
 )
-from servicelib.zip_stream._models import DataSize
+from servicelib.data_streams._models import DataSize
+from servicelib.file_utils import remove_directory
+from servicelib.progress_bar import ProgressBarData
+from servicelib.utils import limited_as_completed, limited_gather
 from settings_library.s3 import S3Settings
 from types_aiobotocore_s3 import S3Client
 from types_aiobotocore_s3.literals import BucketLocationConstraintType
@@ -1596,7 +1596,7 @@ async def test_workflow_compress_s3_objects_and_local_files_in_a_single_archive_
         await simcore_s3_api.upload_object_from_file_stream(
             with_s3_bucket,
             archive_s3_object_key,
-            get_zip_archive_file_stream(
+            get_zip_data_stream(
                 archive_file_entries,
                 progress_bar=progress_bar,
                 chunk_size=MULTIPART_COPY_THRESHOLD,

packages/service-library/src/servicelib/zip_stream/__init__.py renamed to packages/service-library/src/servicelib/data_streams/__init__.py

@@ -2,14 +2,14 @@
 from ._input import DiskStreamReader
 from ._models import ArchiveEntries, ArchiveFileEntry, StreamData
 from ._output import DiskStreamWriter
-from ._zipper import get_zip_archive_file_stream
+from ._zipper import get_zip_data_stream
 
 __all__: tuple[str, ...] = (
     "ArchiveEntries",
     "ArchiveFileEntry",
     "DEFAULT_READ_CHUNK_SIZE",
     "DiskStreamReader",
     "DiskStreamWriter",
-    "get_zip_archive_file_stream",
+    "get_zip_data_stream",
     "StreamData",
 )

packages/service-library/src/servicelib/zip_stream/_constants.py renamed to packages/service-library/src/servicelib/data_streams/_constants.py

@@ -22,7 +22,7 @@ async def _member_files_iter(
         )
 
 
-async def get_zip_archive_file_stream(
+async def get_zip_data_stream(
     archive_files: ArchiveEntries,
     *,
     progress_bar: ProgressBarData | None = None,

packages/service-library/src/servicelib/zip_stream/_input.py renamed to packages/service-library/src/servicelib/data_streams/_input.py

@@ -15,15 +15,15 @@
     get_relative_to,
 )
 from servicelib.archiving_utils import unarchive_dir
-from servicelib.file_utils import remove_directory
-from servicelib.progress_bar import ProgressBarData
-from servicelib.s3_utils import FileLikeFileStreamReader
-from servicelib.zip_stream import (
+from servicelib.data_streams import (
     ArchiveEntries,
     DiskStreamReader,
     DiskStreamWriter,
-    get_zip_archive_file_stream,
+    get_zip_data_stream,
 )
+from servicelib.file_utils import remove_directory
+from servicelib.progress_bar import ProgressBarData
+from servicelib.s3_utils import FileLikeFileStreamReader
 
 
 def _ensure_dir(path: Path) -> Path:
@@ -116,7 +116,7 @@ async def test_get_zip_archive_file_stream(
         progress_report_cb=mocked_progress_bar_cb,
         description="root_bar",
     ) as root:
-        file_stream = get_zip_archive_file_stream(
+        file_stream = get_zip_data_stream(
             archive_files, progress_bar=root, chunk_size=1024
         )