def __init__()

in dataflux_core/fast_list.py [0:0]

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

    def __init__(
        self,
        name: str,
        gcs_project: str,
        bucket: str,
        send_work_stealing_needed_queue: "multiprocessing.Queue[str]",
        heartbeat_queue: "multiprocessing.Queue[str]",
        direct_work_available_queue: "multiprocessing.Queue[tuple[str, str]]",
        idle_queue: "multiprocessing.Queue[str]",
        unidle_queue: "multiprocessing.Queue[str]",
        results_queue: "multiprocessing.Queue[set[tuple[str, int]]]",
        metadata_queue: "multiprocessing.Queue[tuple[str, int]]",
        error_queue: "multiprocessing.Queue[Exception]",
        start_range: str,
        end_range: str,
        retry_config:
        "google.api_core.retry.retry_unary.Retry" = MODIFIED_RETRY,
        client: storage.Client = None,
        skip_compose: bool = True,
        list_directory_objects: bool = False,
        prefix: str = "",
        allowed_storage_classes: list[str] = DEFAULT_ALLOWED_CLASS,
        max_retries: int = 5,