Package pyspark :: Module daemon
[frames] | no frames]

Module daemon

source code

Functions
 
should_exit() source code
 
compute_real_exit_code(exit_code) source code
 
worker(listen_sock) source code
 
launch_worker(listen_sock) source code
 
manager() source code
Variables
  POOLSIZE = 4
  exit_flag = multiprocessing.Value(c_bool, False)