MCPcopy
hub / github.com/ray-project/ray / add_node

Method add_node

python/ray/tests/test_draining.py:527–528  ·  view source on GitHub ↗
(self, node_id)

Source from the content-addressed store, hash-verified

525 self._node_ids = Counter()
526
527 def add_node(self, node_id):
528 self._node_ids.update([node_id])
529
530 def nodes(self):
531 return self._node_ids

Callers 15

test_usage_lib_cluster_metadata_generationFunction · 0.45
test_usage_stats_enabled_endpointFunction · 0.45
test_get_cluster_idFunction · 0.45
test_usage_lib_get_total_num_running_jobs_to_reportFunction · 0.45
test_usage_lib_get_total_num_alive_nodes_to_reportFunction · 0.45
test_usage_lib_report_dataFunction · 0.45
test_usage_report_e2eFunction · 0.45
test_first_usage_report_delayedFunction · 0.45
test_usage_report_disabledFunction · 0.45
test_usage_file_error_messageFunction · 0.45
test_usage_stats_tagsFunction · 0.45
test_usage_stats_gcs_query_failureFunction · 0.45

Calls 1

updateMethod · 0.45

Tested by

no test coverage detected