Skip to content

feat: support multi CU workers #2766

feat: support multi CU workers

feat: support multi CU workers #2766

GitHub Actions / nox report succeeded Aug 19, 2024 in 1s

316 passed, 0 failed and 0 skipped

Tests passed successfully

✅ target/nextest/ci/junit.xml

316 tests were completed in 382s with 316 passed, 0 failed and 0 skipped.

Test suite Passed Failed Skipped Time
aquamarine 9✅ NaNms
chain-connector 20✅ NaNms
chain-data 2✅ NaNms
chain-listener 10✅ NaNms
core-distributor 22✅ NaNms
fluence-libp2p 1✅ NaNms
health 4✅ NaNms
kademlia 3✅ NaNms
log-format 4✅ NaNms
nox 17✅ NaNms
nox-tests::boolean_test 1✅ NaNms
nox-tests::builtin 58✅ NaNms
nox-tests::client_api 1✅ NaNms
nox-tests::echo_particle 1✅ NaNms
nox-tests::kademlia 2✅ NaNms
nox-tests::local_vm 1✅ NaNms
nox-tests::modules 3✅ NaNms
nox-tests::services 4✅ NaNms
nox-tests::spells 38✅ NaNms
nox-tests::tests 15✅ NaNms
nox-tests::tetraplets 1✅ NaNms
nox-tests::topology 3✅ NaNms
nox-tests::vault 4✅ NaNms
nox-tests::workers 2✅ NaNms
particle-args 1✅ NaNms
particle-builtins 2✅ NaNms
particle-modules 9✅ NaNms
particle-protocol 5✅ NaNms
particle-services 12✅ NaNms
server-config 23✅ NaNms
service-modules 5✅ NaNms
spell-event-bus 16✅ NaNms
spell-service-api 5✅ NaNms
types 2✅ NaNms
vm-utils 2✅ NaNms
workers 8✅ NaNms

✅ aquamarine

✅ health::tests::test_vm_pool_health_empty
✅ health::tests::test_vm_pool_health_partial
✅ health::tests::test_vm_pool_health_full
✅ particle_data_store::tests::test_detect_anomaly
✅ particle_data_store::tests::test_cleanup_data
✅ particle_data_store::tests::test_initialize
✅ particle_data_store::tests::test_store_and_read_data
✅ health::tests::test_vm_pool_health_concurrent_access
✅ plumber::tests::ignore_expired

✅ chain-connector

✅ connector::tests::get_commitment_status
✅ connector::tests::submit_proof_not_active
✅ connector::tests::submit_proof
✅ connector::tests::test_batch_init_request
✅ connector::tests::test_get_app_cid_empty
✅ connector::tests::test_activate_worker
✅ connector::tests::test_get_compute_units
✅ connector::tests::test_get_current_commitment_id_some
✅ connector::tests::test_get_current_commitment_id_none
✅ connector::tests::test_get_deals_no_deals
✅ connector::tests::test_get_deals
✅ connector::tests::test_get_receipts
✅ connector::tests::test_get_receipts_several
✅ function::capacity::tests::decode_commitment_status
✅ eth_call::tests::serialize_eth_call
✅ function::capacity::tests::decode_commitment_status_removed
✅ function::offer::tests::decode_compute_peer
✅ function::offer::tests::decode_compute_unit
✅ function::offer::tests::decode_compute_peer_no_commitment
✅ function::offer::tests::decode_compute_unit_no_deal_no_worker

✅ chain-data

✅ block_header::tests::test_block_header_from_json
✅ utils::tests::peer_id_test

✅ chain-listener

✅ event::cc_activated::test::test_chain_parsing_ok
✅ event::cc_activated::test::test_cc_activated_topic
✅ event::compute_unit_matched::tests::peer_id
✅ event::compute_unit_matched::tests::topic
✅ event::compute_unit_matched::tests::parse
✅ event::unit_activated::test::test_unit_activated_topic
✅ event::unit_activated::test::test_chain_parsing_ok
✅ event::unit_deactivated::test::test_unit_activated_topic
✅ event::unit_deactivated::test::test_chain_parsing_ok
✅ persistence::tests::proof_tracker_test

✅ core-distributor

✅ core_range::tests::compare_ranges
✅ core_range::tests::empty_slice_convert
✅ core_range::tests::fmt
✅ core_range::tests::empty_parsing_test_3
✅ core_range::tests::last
✅ core_range::tests::range_is_inclusive
✅ core_range::tests::range_parsing_test
✅ core_range::tests::slice_convert
✅ core_range::tests::values_parsing_test
✅ core_range::tests::wrong_parsing_test
✅ core_range::tests::wrong_parsing_test_2
✅ core_range::tests::wrong_parsing_test_3
✅ core_range::tests::wrong_parsing_test_4
✅ distributor::tests::test_acquire_and_switch_strict
✅ distributor::tests::test_acquire_and_release_strict
✅ distributor::tests::test_acquire_error_message_strict
✅ distributor::tests::test_acquire_and_release_round_robin
✅ distributor::tests::test_reassignment_strict
✅ distributor::tests::test_workload_assign_error
✅ distributor::tests::test_reassignment_round_robin
✅ distributor::tests::test_wrong_range
✅ persistence::tests::test_serde

✅ fluence-libp2p

✅ serde::tests::multihash

✅ health

✅ tests::test_health_check_registry_empty
✅ tests::test_health_check_registry_multiple_checks
✅ tests::test_health_check_registry_single_check_fail
✅ tests::test_health_check_registry_single_check_pass

✅ kademlia

✅ behaviour::tests::dont_repeat_discovery
✅ behaviour::tests::discovery_heavy
✅ behaviour::tests::ban

✅ log-format

✅ tests::test_asni_info
✅ tests::test_simple_info
✅ tests::test_simple_info_with_span
✅ tests::test_simple_info_without_spans

✅ nox

✅ health::tests::new_health_instance_should_have_default_status_false
✅ health::tests::on_bootstrap_failed_should_set_status_to_false
✅ health::tests::on_bootstrap_finished_should_set_status_to_true
✅ health::tests::status_error_should_contain_expected_message
✅ health::tests::status_should_return_error_if_bootstrap_failed
✅ health::tests::test_bootstrap_nodes_health_all_connected
✅ health::tests::status_should_return_ok_if_bootstrap_finished
✅ health::tests::test_bootstrap_nodes_health_partial_connected
✅ health::tests::test_bootstrap_nodes_health_concurrent_access
✅ http::tests::test_version_route
✅ http::tests::test_config_endpoint
✅ http::tests::test_health_route_fail_checks
✅ http::tests::test_health_route_empty_registry
✅ http::tests::test_health_route_success_checks
✅ http::tests::test_health_route_warn_checks
✅ http::tests::test_peer_id_route
✅ node::tests::run_node

✅ nox-tests::boolean_test

✅ pass_boolean

✅ nox-tests::builtin

✅ add_alias_list
✅ array
✅ aliases_restart
✅ array_diff
✅ array_intersect
✅ array_dedup
✅ array_sdiff
✅ array_length
✅ array_slice
✅ array_slice_out_of_bounds
✅ array_slice_wrong_args_count
✅ array_slice_wrong_second_arg
✅ array_slice_wrong_third_arg
✅ array_sum
✅ base58_bytes_builtins
✅ base58_string_builtins
✅ cmp_cmp
✅ cmp_gt
✅ empty_array_slice
✅ cmp_le
✅ concat
✅ debug_stringify
✅ identify
✅ json_builtins
✅ index_by_math
✅ math_add
✅ identity
✅ kad_merge
✅ math_div
✅ math_log
✅ math_fmul
✅ math_pow
✅ math_mul
✅ math_rem
✅ math_sub
✅ neighborhood
✅ non_owner_remove_service
✅ noop
✅ not_array_slice
✅ remove_service
✅ remove_service_by_alias
✅ resolve_alias
✅ resolve_alias_not_exists
✅ resolve_alias_opt
✅ remove_service_restart
✅ resolve_alias_opt_not_exists
✅ resolve_alias_removed
✅ service_mem
✅ service_stats
✅ service_stats_uninitialized
✅ sha256
✅ sig_verify_invalid_signature
✅ timeout_race
✅ sign_invalid_tetraplets_heavy
✅ timeout_wait
✅ timestamp_ms
✅ timestamp_sec
✅ xor_type_error

✅ nox-tests::client_api

✅ call_custom_service

✅ nox-tests::echo_particle

✅ echo_particle

✅ nox-tests::kademlia

✅ neighborhood_heavy
✅ neighborhood_with_addresses_heavy

✅ nox-tests::local_vm

✅ make

✅ nox-tests::modules

✅ test_add_module_by_other_forbidden
✅ test_add_module_mounted_binaries
✅ test_add_module_effectors_forbidden

✅ nox-tests::services

✅ create_service_from_config
✅ test_system_service_override
✅ handle_same_dir_in_preopens_and_mapped_dirs
✅ test_create_service_by_other_forbidden

✅ nox-tests::spells

✅ create_remove_worker
✅ get_worker_peer_id_opt
✅ resolve_alias_wrong_worker
✅ set_alias_by_worker_creator
✅ spell_args_test
✅ spell_call_by_alias
✅ spell_call_by_default_alias
✅ spell_connection_pool_trigger_test
✅ spell_create_worker_same_deal_id_different_peer
✅ spell_create_worker_twice
✅ spell_install_alias
✅ spell_error_handling_test
✅ spell_install_fail_end_sec_before_start
✅ spell_install_fail_end_sec_past
✅ spell_install_fail_large_period
✅ spell_install_ok_empty_config
✅ spell_install_root_scope
✅ spell_peer_id_test
✅ spell_relay_id_test
✅ spell_remove
✅ spell_remove_by_alias
✅ spell_remove_service_as_spell
✅ spell_remove_spell_as_service
✅ spell_return_test
✅ spell_run_oneshot
✅ spell_set_u32
✅ spell_simple_test
✅ spell_store_trigger_config
✅ spell_timer_trigger_mailbox_test
✅ spell_trigger_connection_pool
✅ spell_update_config
✅ spell_update_config_stopped_spell
✅ spell_update_trigger_by_alias
✅ test_activate_deactivate
✅ test_install_by_other_forbidden
✅ test_worker_list
✅ test_spell_list
✅ worker_sig_test

✅ nox-tests::tests

✅ chain_listener::tests::test_cc_activation_flow
✅ chain_listener::tests::test_deal_insufficient_funds_flow
✅ network::loop_topology::fold_fold_fold_par_null
✅ network::loop_topology::fold_fold_fold_par_null_join
✅ network::loop_topology::fold_fold_fold_seq_two_par_null_folds
✅ network::loop_topology::fold_fold_seq_join
✅ network::loop_topology::fold_par_same_node_stream_heavy
✅ network::loop_topology::fold_seq_join
✅ network::loop_topology::fold_fold_pairs_seq_join_heavy
✅ network::loop_topology::join_empty_stream
✅ network::network_explore::get_interfaces
✅ network::loop_topology::fold_via_heavy
✅ network::network_explore::get_modules
✅ network::network_explore::explore_services_heavy
✅ network::network_explore::list_blueprints

✅ nox-tests::tetraplets

✅ test_tetraplets

✅ nox-tests::topology

✅ init_peer_id_heavy
✅ identity_heavy
✅ join_heavy

✅ nox-tests::vault

✅ put_cat_vault
✅ share_file
✅ deploy_from_vault
✅ load_blueprint_from_vault

✅ nox-tests::workers

✅ test_resolve_subnet_on_worker
✅ test_worker_different_deal_ids

✅ particle-args

✅ args::tests::test_next_opt

✅ particle-builtins

✅ builtins::prop_tests::module_config
✅ json::tests::json_parse_string

✅ particle-modules

✅ modules::tests::test_add_blueprint
✅ modules::tests::test_add_module_all_effectors_allowed_effector
✅ modules::tests::test_add_module_all_effectors_allowed_effector_wrong_config
✅ modules::tests::test_add_module_all_effectors_undefined_effector
✅ modules::tests::test_add_module_effector_allowed
✅ modules::tests::test_add_module_effector_forbidden
✅ modules::tests::test_add_module_effector_invalid
✅ modules::tests::test_add_module_pure
✅ modules::tests::test_add_module_get_interface

✅ particle-protocol

✅ libp2p_protocol::codec::fluence::tests::deserialization_test
✅ libp2p_protocol::codec::fluence::tests::isomorphic_codec_test
✅ libp2p_protocol::upgrade::tests::deserialize
✅ particle::tests::test_signature
✅ libp2p_protocol::upgrade::tests::oneshot_channel_test

✅ particle-services

✅ app_services::tests::test_add_alias_forbidden
✅ app_services::tests::test_add_alias_no_service
✅ app_services::tests::test_add_alias
✅ app_services::tests::test_add_alias_twice
✅ app_services::tests::test_add_alias_repeated
✅ app_services::tests::test_persisted_service
✅ health::tests::test_persisted_service_health_not_started
✅ health::tests::persisted_service_health_concurrent_access
✅ health::tests::test_persisted_service_health_started_with_errors
✅ health::tests::test_persisted_service_health_started_without_errors
✅ app_services::tests::test_get_interface_cache
✅ persistence::tests::test_persistence

✅ server-config

✅ resolved_config::tests::load_allowed_binaries_with_env
✅ resolved_config::tests::load_allowed_binaries_with_file
✅ resolved_config::tests::load_base58_keypair
✅ resolved_config::tests::load_base64_keypair
✅ resolved_config::tests::load_base58_secret_key
✅ resolved_config::tests::load_base64_secret_key
✅ resolved_config::tests::load_empty_config
✅ resolved_config::tests::load_config_simple
✅ resolved_config::tests::load_empty_keypair
✅ resolved_config::tests::load_env_upgrade_timeout
✅ resolved_config::tests::load_file_upgrade_timeout
✅ resolved_config::tests::load_file_with_custom_network
✅ resolved_config::tests::load_file_with_vm_config
✅ resolved_config::tests::load_http_port_with_args
✅ resolved_config::tests::load_multiple_configs
✅ resolved_config::tests::load_http_port_with_env
✅ resolved_config::tests::load_path_keypair_generate
✅ resolved_config::tests::load_tracing_disabled_with_env
✅ resolved_config::tests::load_tracing_disabled_with_args
✅ resolved_config::tests::load_tracing_disabled_with_file
✅ resolved_config::tests::load_tracing_otlp_with_env
✅ resolved_config::tests::load_tracing_otlp_with_args
✅ resolved_config::tests::load_tracing_otlp_with_file

✅ service-modules

✅ modules::blueprint::test_blueprint_hash
✅ modules::file_names::tests::is_bp
✅ modules::file_names::tests::is_srvc
✅ modules::file_names::tests::is_wasm
✅ modules::file_names::tests::module_fname

✅ spell-event-bus

✅ bus::tests::test_resubscribing_same_spell
✅ bus::tests::test_subscribe_connect
✅ bus::tests::test_double_subscribe_before_run
✅ bus::tests::test_subscribe_many_spells_with_diff_event_types
✅ bus::tests::test_subscribe_many
✅ bus::tests::test_unsubscribe
✅ config::trigger_config_tests::test_both_types_ended
✅ config::trigger_config_tests::test_both_types_ok
✅ config::trigger_config_tests::test_peer_events
✅ config::trigger_config_tests::test_reschedule_fail_ended
✅ bus::tests::test_subscribe_one
✅ config::trigger_config_tests::test_reschedule_fail_oneshot_executed
✅ bus::tests::test_subscribe_oneshot
✅ config::trigger_config_tests::test_reschedule_ok_oneshot_start_future
✅ config::trigger_config_tests::test_reschedule_ok_periodic
✅ config::trigger_config_tests::test_reschedule_ok_periodic_end_future

✅ spell-service-api

✅ tests::test_counter
✅ tests::test_script
✅ tests::test_kv
✅ tests::test_trigger_event
✅ tests::test_trigger_config

✅ types

✅ deal_id::tests::deal_id
✅ peer_id::tests::peerid

✅ vm-utils

✅ vm_utils::tests::test_prepare_xml
✅ vm_utils::tests::test_vm_creation

✅ workers

✅ key_storage::tests::test_key_pair_creation_and_removal
✅ key_storage::tests::test_key_storage_creation
✅ key_storage::tests::test_persistence
✅ workers::tests::test_persistence
✅ workers::tests::test_worker_creation
✅ workers::tests::test_worker_creation_dupes
✅ workers::tests::test_worker_remove
✅ workers::tests::test_workers_creation