in dataflux_core/download.py [0:0]
def compose(
project_name: str,
bucket_name: str,
destination_blob_name: str,
objects: list[tuple[str, int]],
storage_client: object = None,
retry_config: "google.api_core.retry.retry_unary.Retry" = MODIFIED_RETRY,