def df_download_thread()

in dataflux_core/download.py [0:0]

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

def df_download_thread(
    results_queue: queue.Queue[list[bytes]],
    project_name: str,
    bucket_name: str,
    objects: list[tuple[str, int]],
    storage_client: object = None,
    dataflux_download_optimization_params:
    DataFluxDownloadOptimizationParams = None,
    retry_config=MODIFIED_RETRY,