提交 fd701b85 编写于 作者: Y yanghaitao

set monitor sampling interval through json file

上级 5a886794
......@@ -41,7 +41,7 @@ Status ConfigManager::FromJson(const nlohmann::json &j) {
set_worker_connector_size(j.value("workerConnectorSize", worker_connector_size_));
set_op_connector_size(j.value("opConnectorSize", op_connector_size_));
set_seed(j.value("seed", seed_));
set_monitor_sampling_interval(j.value("monitorSamplingInterval"));
set_monitor_sampling_interval(j.value("monitorSamplingInterval", monitor_sampling_interval_));
return Status::OK();
}
......
......@@ -186,7 +186,7 @@ class ConfigurationManager:
>>> # "workerConnectorSize": 16,
>>> # "opConnectorSize": 16,
>>> # "seed": 5489,
>>> # "monitorSamplingInterval": 30
>>> # "monitorSamplingInterval": 30
>>> # }
"""
self.config.load(file)
......
......@@ -5,6 +5,5 @@
"workerConnectorSize": 16,
"opConnectorSize": 16,
"seed": 5489,
"monitor_sampling_interval": 15
"monitorSamplingInterval": 15
}
......@@ -46,7 +46,7 @@ def test_basic():
# assert ds.config.get_worker_connector_size() == 16
assert ds.config.get_prefetch_size() == 16
assert ds.config.get_seed() == 5489
# assert ds.config.get_monitor_sampling_interval() == 15
assert ds.config.get_monitor_sampling_interval() == 15
# ds.config.set_rows_per_buffer(1)
ds.config.set_num_parallel_workers(2)
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册