Method join

python/dgl/distributed/dist_context.py:202–205 · view source on GitHub ↗

Join the close process of worker pool

(self)

Source from the content-addressed store, hash-verified

200	time.sleep(0.5) # Fix for early python version
201
202	def join(self):
203	"""Join the close process of worker pool"""
204	for i in range(self.num_workers):
205	self.process_list[i].join()
206
207
208	def initialize(

get_node_partidsFunction · 0.45

read_orig_idsFunction · 0.45

get_killed_pidsFunction · 0.45

get_remote_pidsFunction · 0.45

get_all_remote_pidsFunction · 0.45

wrap_cmd_with_extra_envvarsFunction · 0.45

submit_jobsFunction · 0.45

_validate_resultsFunction · 0.45

convert_confFunction · 0.45

_find_c_etypes_in_partitionFunction · 0.45

dispatch_data.pyFile · 0.45

get_launch_cmdFunction · 0.45

no outgoing calls

_single_machine_runFunction · 0.36

_prepare_test_dataFunction · 0.36

test_lookup_serviceFunction · 0.36

test_parmetis_preprocessingFunction · 0.36

test_parmetis_postprocessingFunction · 0.36

test_parmetis_wrapperFunction · 0.36

create_random_heteroFunction · 0.36

do_convert_and_checkFunction · 0.36

test_submit_jobsFunction · 0.36

test_array_readwriterFunction · 0.36

_chunk_graphFunction · 0.36

create_chunked_datasetFunction · 0.36