code: def listen(client, network_interface=""):
      worker_id_maps = client.run(
          get_communication_port, network_interface, wait=True
      )
      client.run(set_id_mappings_on_worker, worker_id_maps, wait=True)
      return worker_id_maps
  
file_path: blazingsql/pyblazing/pyblazing/apiv2/comms.py
imports: import errno
  import random
  import socket
  import netifaces
  from dask.distributed import default_client
  from distributed import get_worker
  from distributed.comm.addressing import parse_host_port
  from distributed.comm.ucx import UCXConnector, UCXListener
  from ucp.endpoint_reuse import EndpointReuse
label_desc: Use image node_id 4 for calling a global function with example usage: listen(client, network_interface) and returns: worker_id_maps