code: def test_collect_ports(setup_cluster):
      session = setup_cluster
      workers = [
          pool.external_address
          for pool in session._session.client._cluster._worker_pools
      ]
      # make sure assert works inside execution of collect ports
      collect_ports(workers * 2).execute(session=session)
  
label_desc: Use image node_id 1 for calling a global function with example usage: test_collect_ports(setup_cluster) without return types