def upload_chunks_concurrently_from_bytesio()

in dataflux_pytorch/multipart_upload/multipart.py [0:0]

• 11 lines of code
• 1 McCabe index (conditional complexity)

def upload_chunks_concurrently_from_bytesio(
    bytesio,
    blob,
    content_type=None,
    chunk_size=TM_DEFAULT_CHUNK_SIZE,
    deadline=None,
    max_workers=DEFAULT_MAX_WORKERS,
    *,
    checksum="crc32c",
    timeout=_DEFAULT_TIMEOUT,
    retry=DEFAULT_RETRY,