code: def test_apportion_ports(args, expect):
      assert _apportion_ports(*args) == expect
  
imports: from __future__ import annotations
  import asyncio
  import os
  import signal
  import subprocess
  import sys
  from multiprocessing import cpu_count
  from time import sleep
  import pytest
  from click.testing import CliRunner
  from dask.utils import tmpfile
  from distributed import Client
  from distributed.cli.dask_worker import _apportion_ports, main
  from distributed.compatibility import LINUX, WINDOWS
  from distributed.deploy.utils import nprocesses_nthreads
  from distributed.metrics import time
  from distributed.utils import open_port
  from distributed.utils_test import gen_cluster, inc, popen, requires_ipv6, wait_for_log_line
label_desc: Use image node_id 1 for calling a global function with example usage: test_apportion_ports(args, expect) without return types