def run_list_worker()

in dataflux_core/fast_list.py [0:0]

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

def run_list_worker(
    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,
    prefix: str = "",
    allowed_storage_classes: list[str] = DEFAULT_ALLOWED_CLASS,