Avatar for the equinor user
equinor
ert
BlogDocsChangelog

Do heartbeat on clients

#9798
Comparing
xjules:fix_monitor
(
526882e
) with
main
(
4057a98
)
CodSpeed Performance Gauge
-1%
Improvements
0
Regressions
0
Untouched
24
New
0
Dropped
0
Ignored
0

Benchmarks

Passed

test_direct_dark_performance_with_storage[gen_x: 20, sum_x: 20 reals: 10-gen_data-get_record_observations]
tests/ert/performance_tests/test_dark_storage_performance.py::test_direct_dark_performance_with_storage[gen_x: 20, sum_x: 20 reals: 10-gen_data-get_record_observations]
CodSpeed Performance Gauge
+1%
1.4 ms
1.4 ms
test_direct_dark_performance[gen_x: 20, sum_x: 20 reals: 10-summary-get_parameters]
tests/ert/performance_tests/test_dark_storage_performance.py::test_direct_dark_performance[gen_x: 20, sum_x: 20 reals: 10-summary-get_parameters]
CodSpeed Performance Gauge
+1%
149.2 µs
148.4 µs
test_direct_dark_performance[gen_x: 20, sum_x: 20 reals: 10-gen_data_with_obs-get_parameters]
tests/ert/performance_tests/test_dark_storage_performance.py::test_direct_dark_performance[gen_x: 20, sum_x: 20 reals: 10-gen_data_with_obs-get_parameters]
CodSpeed Performance Gauge
0%
144.3 µs
143.7 µs
test_direct_dark_performance[gen_x: 20, sum_x: 20 reals: 10-summary_with_obs-get_parameters]
tests/ert/performance_tests/test_dark_storage_performance.py::test_direct_dark_performance[gen_x: 20, sum_x: 20 reals: 10-summary_with_obs-get_parameters]
CodSpeed Performance Gauge
0%
144.4 µs
143.9 µs
test_direct_dark_performance[gen_x: 20, sum_x: 20 reals: 10-summary_with_obs-get_record_csv]
tests/ert/performance_tests/test_dark_storage_performance.py::test_direct_dark_performance[gen_x: 20, sum_x: 20 reals: 10-summary_with_obs-get_record_csv]
CodSpeed Performance Gauge
0%
13.1 ms
13 ms
test_direct_dark_performance[gen_x: 20, sum_x: 20 reals: 10-gen_data-get_parameters]
tests/ert/performance_tests/test_dark_storage_performance.py::test_direct_dark_performance[gen_x: 20, sum_x: 20 reals: 10-gen_data-get_parameters]
CodSpeed Performance Gauge
0%
145.2 µs
144.7 µs
test_direct_dark_performance[gen_x: 20, sum_x: 20 reals: 10-summary-get_record_csv]
tests/ert/performance_tests/test_dark_storage_performance.py::test_direct_dark_performance[gen_x: 20, sum_x: 20 reals: 10-summary-get_record_csv]
CodSpeed Performance Gauge
0%
13.3 ms
13.3 ms
test_snapshot_handling_of_forward_model_events[10-10-1]
tests/ert/performance_tests/test_snapshot.py::test_snapshot_handling_of_forward_model_events[10-10-1]
CodSpeed Performance Gauge
0%
10.5 ms
10.5 ms
test_direct_dark_performance[gen_x: 20, sum_x: 20 reals: 10-gen_data-get_record_parquet]
tests/ert/performance_tests/test_dark_storage_performance.py::test_direct_dark_performance[gen_x: 20, sum_x: 20 reals: 10-gen_data-get_record_parquet]
CodSpeed Performance Gauge
0%
17.2 ms
17.2 ms
test_direct_dark_performance[gen_x: 20, sum_x: 20 reals: 10-gen_data_with_obs-get_record_csv]
tests/ert/performance_tests/test_dark_storage_performance.py::test_direct_dark_performance[gen_x: 20, sum_x: 20 reals: 10-gen_data_with_obs-get_record_csv]
CodSpeed Performance Gauge
0%
11.1 ms
11.1 ms
test_snapshot_handling_of_forward_model_events[10-100-1]
tests/ert/performance_tests/test_snapshot.py::test_snapshot_handling_of_forward_model_events[10-100-1]
CodSpeed Performance Gauge
0%
97.6 ms
97.6 ms
test_and_benchmark_adaptive_localization_with_fields
tests/ert/performance_tests/test_analysis.py::test_and_benchmark_adaptive_localization_with_fields
CodSpeed Performance Gauge
0%
3 s
3 s
test_speed_performance_of_doing_es_update[setup_es_benchmark0]
tests/ert/performance_tests/test_obs_and_responses_performance.py::test_speed_performance_of_doing_es_update[setup_es_benchmark0]
CodSpeed Performance Gauge
0%
83.8 ms
83.8 ms
test_snapshot_handling_of_forward_model_events[100-10-1]
tests/ert/performance_tests/test_snapshot.py::test_snapshot_handling_of_forward_model_events[100-10-1]
CodSpeed Performance Gauge
0%
102.3 ms
102.4 ms
test_direct_dark_performance[gen_x: 20, sum_x: 20 reals: 10-summary-get_record_parquet]
tests/ert/performance_tests/test_dark_storage_performance.py::test_direct_dark_performance[gen_x: 20, sum_x: 20 reals: 10-summary-get_record_parquet]
CodSpeed Performance Gauge
0%
20.6 ms
20.6 ms
test_direct_dark_performance[gen_x: 20, sum_x: 20 reals: 10-summary_with_obs-get_record_parquet]
tests/ert/performance_tests/test_dark_storage_performance.py::test_direct_dark_performance[gen_x: 20, sum_x: 20 reals: 10-summary_with_obs-get_record_parquet]
CodSpeed Performance Gauge
0%
20 ms
20.1 ms
test_direct_dark_performance[gen_x: 20, sum_x: 20 reals: 10-gen_data-get_record_csv]
tests/ert/performance_tests/test_dark_storage_performance.py::test_direct_dark_performance[gen_x: 20, sum_x: 20 reals: 10-gen_data-get_record_csv]
CodSpeed Performance Gauge
-1%
11.1 ms
11.2 ms
test_direct_dark_performance[gen_x: 20, sum_x: 20 reals: 10-gen_data_with_obs-get_record_parquet]
tests/ert/performance_tests/test_dark_storage_performance.py::test_direct_dark_performance[gen_x: 20, sum_x: 20 reals: 10-gen_data_with_obs-get_record_parquet]
CodSpeed Performance Gauge
-1%
17.2 ms
17.3 ms
test_load_from_context[gen_x: 20, sum_x: 20 reals: 10]
tests/ert/performance_tests/enkf/test_load_state.py::test_load_from_context[gen_x: 20, sum_x: 20 reals: 10]
CodSpeed Performance Gauge
-1%
6.3 ms
6.3 ms
test_time_performance_of_joining_observations_and_responses[setup_benchmark0]
tests/ert/performance_tests/test_obs_and_responses_performance.py::test_time_performance_of_joining_observations_and_responses[setup_benchmark0]
CodSpeed Performance Gauge
-1%
12.3 ms
12.5 ms
test_snapshot_handling_of_forward_model_events[10-10-10]
tests/ert/performance_tests/test_snapshot.py::test_snapshot_handling_of_forward_model_events[10-10-10]
CodSpeed Performance Gauge
-1%
37.8 ms
38.4 ms
test_direct_dark_performance_with_storage[gen_x: 20, sum_x: 20 reals: 10-summary-get_record_observations]
tests/ert/performance_tests/test_dark_storage_performance.py::test_direct_dark_performance_with_storage[gen_x: 20, sum_x: 20 reals: 10-summary-get_record_observations]
CodSpeed Performance Gauge
-3%
1.3 ms
1.3 ms
test_direct_dark_performance_with_storage[gen_x: 20, sum_x: 20 reals: 10-gen_data_with_obs-get_record_observations]
tests/ert/performance_tests/test_dark_storage_performance.py::test_direct_dark_performance_with_storage[gen_x: 20, sum_x: 20 reals: 10-gen_data_with_obs-get_record_observations]
CodSpeed Performance Gauge
-4%
2.4 ms
2.5 ms
test_direct_dark_performance_with_storage[gen_x: 20, sum_x: 20 reals: 10-summary_with_obs-get_record_observations]
tests/ert/performance_tests/test_dark_storage_performance.py::test_direct_dark_performance_with_storage[gen_x: 20, sum_x: 20 reals: 10-summary_with_obs-get_record_observations]
CodSpeed Performance Gauge
-6%
3.9 ms
4.1 ms

Commits

Click on a commit to change the comparison range
Base
main
4057a98
-11%
zmq: implement task for heeartbeats on clients to detect reconnection Heartbeat task sends HEARTBEAT to all the clients (ie. Monitor) at client.HEARTBEAT_TIMEOUT intervals. Clients do not reply, just process the message. If client detects longer delay between two heartbeats, the client will send CONNECT to evaluator in addition; ie. getting the connection re-established after a break. This is to simulate re-connection. Each CONNECT_MSG will then trigger sending FullSnapshot from the ensemble evaluator. Initially HEARTBEAT_TIMEOUT is set to 5 seconds while Monitor accepts 10 seconds at max as a delay. Additionally, initial connection will now undergo same amount of retries as standard messages.
8589c06
5 days ago
by xjules
+11%
Add test that evaluator sends HEARTBEATs to monitor
526882e
8 hours ago
by xjules
© 2025 CodSpeed Technology
Home Terms PrivacyDocs