code: def load_data(edge_path):
      src, dst = [], []
      with open(edge_path, "r") as f:
          for i in tqdm.tqdm(f):
              s, d, _ = i.split()
              s = int(s)
              d = int(d)
              src.append(s)
              dst.append(d)
              dst.append(s)
              src.append(d)
      src = np.array(src, dtype="int64")
      dst = np.array(dst, dtype="int64")
      return src, dst
  
imports: import sys
  import json
  import logging
  from collections import defaultdict
  import tqdm
  import redis
  from redis._compat import b, unicode, bytes, long, basestring
  from rediscluster.nodemanager import NodeManager
  from rediscluster.crc import crc16
  import argparse
  import time
  import pickle
  import numpy
  import scipy.sparse
label_desc: Use image node_id 4 for calling a global function with example usage: load_data(edge_path) and returns: src,  dst