code: def remove_leakage_edges(edges_src, edges_dst, final_index):
      """remove leakage edges"""
      ego_pairs = final_index.reshape([-1, 2])
      magic_number = 27644437
      log.info("magic number: %s" % magic_number)
      hashnum = ego_pairs[:, 0] * magic_number + ego_pairs[:, 1]
      hashnum = paddle.unique(hashnum)
  
      tmp_edges_dst = paddle.cast(edges_dst, dtype="int32")
      tmp_edges_src = paddle.cast(edges_src, dtype="int32")
      edge_hash = tmp_edges_dst * magic_number + tmp_edges_src
      edge_hash = paddle.reshape(edge_hash, [-1])
      mask1 = remove_duplitcate(edge_hash, hashnum)
  
      edge_hash = tmp_edges_src * magic_number + tmp_edges_dst
      edge_hash = paddle.reshape(edge_hash, [-1])
      mask2 = remove_duplitcate(edge_hash, hashnum)
  
      mask = paddle.logical_and(mask1, mask2)
  
      return edges_src[mask], edges_dst[mask]
  
imports: import os
  import sys
  import math
  import time
  import numpy
  import pickle
  import paddle
  import paddle.fluid
  import paddle.fluid.layers
  import paddle.static
  from paddle.common_ops_import import LayerHelper, check_type, check_variable_and_dtype
  from paddle.fluid.framework import Variable
  import pgl
  from pgl.utils.logger import log
label_desc: Use image node_id 18 for calling a global function with example usage: remove_leakage_edges(edges_src, edges_dst, final_index) and returns: edges_src,  edges_dst