GeneralService: bump up iter_min_period to 3.

Author: gmelikov

genesis_core/cmd/gservice.py

@@ -54,7 +54,7 @@ def main():
 
     engines.engine_factory.configure_postgresql_factory(CONF)
 
-    service = GeneralService(iter_min_period=1)
+    service = GeneralService()
 
     service.start()
 

genesis_core/gservice/service.py

@@ -63,8 +63,8 @@
 
 
 class GeneralService(basic.BasicService):
-    def __init__(self, iter_min_period=1, iter_pause=0.1):
-        super().__init__(iter_min_period, iter_pause)
+    def __init__(self, iter_min_period=3, iter_pause=0.1):
+        super().__init__(iter_min_period=iter_min_period, iter_pause=iter_pause)
 
         # TODO(akremenetsky): Form a pipliene from the configuration
         # and entry points
@@ -89,15 +89,14 @@ def __init__(self, iter_min_period=1, iter_pause=0.1):
             pool_weighters=pool_weighters,
             machine_filters=machine_filters,
             machine_weighters=machine_weighters,
-            iter_min_period=1,
-            iter_pause=0.1,
+            iter_min_period=iter_min_period,
         )
-        n_network = n_network_service.NetworkService(iter_min_period=1, iter_pause=0.1)
+        n_network = n_network_service.NetworkService(iter_min_period=iter_min_period)
         node_builder = node_builder_svc.NodeBuilderService(
-            iter_min_period=1, iter_pause=0.1
+            iter_min_period=iter_min_period
         )
         volume_builder = volume_builder_svc.VolumeBuilderService(
-            iter_min_period=1, iter_pause=0.1
+            iter_min_period=iter_min_period
         )
         pool_driver = ua_pool_drivers.PoolAgentDriver(
             meta_file="/var/lib/genesis/genesis_core/pool_agent_meta.json"
@@ -125,7 +124,8 @@ def __init__(self, iter_min_period=1, iter_pause=0.1):
 
         # Infra scheduler
         infra_scheduler = ua_scheduler_service.UniversalAgentSchedulerService(
-            capabilities=["set_agent_node", "target_node_set"]
+            capabilities=["set_agent_node", "target_node_set"],
+            iter_min_period=iter_min_period,
         )
 
         # Infra agent
@@ -171,35 +171,36 @@ def __init__(self, iter_min_period=1, iter_pause=0.1):
         pool_builder_service = pool_builder_svc.PoolBuilderService(
             uuid=sys_uuid.uuid5(ua_utils.system_uuid(), "pool_builder"),
             orch_client=orch_db.DatabaseOrchClient(),
+            iter_min_period=iter_min_period,
         )
 
         # ValuesStore
         vs_builder_service = vs_builder_svc.VSBuilderService(
             uuid=sys_uuid.uuid5(ua_utils.system_uuid(), "vs_builder"),
             orch_client=orch_db.DatabaseOrchClient(),
+            iter_min_period=iter_min_period,
         )
 
-        cfg_service = config_service.ConfigServiceBuilder()
-        secret_svc = secret_service.SecretServiceBuilder()
-        event_sender = senders.EventSenderService.build_from_config()
-        em_builder = em_builders.ElementManagerBuilder(
-            iter_min_period=1, iter_pause=0.1
+        cfg_service = config_service.ConfigServiceBuilder(
+            iter_min_period=iter_min_period,
+        )
+        secret_svc = secret_service.SecretServiceBuilder(
+            iter_min_period=iter_min_period,
         )
+        event_sender = senders.EventSenderService.build_from_config()
+        em_builder = em_builders.ElementManagerBuilder(iter_min_period=iter_min_period)
         janitor = janitor_service.ExpiredEmailConfirmationCodeJanitorService(
             iter_min_period=60 * 60,
-            iter_pause=0,
         )
 
         # Telemetry
         telemetry = telemetry_service.TelemetryService(
             iter_min_period=60 * 60,
-            iter_pause=0,
         )
 
         # DNS Sync
         dns_sync = dns_sync_service.DNSSyncService(
-            iter_min_period=5,
-            iter_pause=0,
+            iter_min_period=iter_min_period * 2,
         )
 
         self._services = [

genesis_core/tests/functional/restapi/iam/test_reset_password.py

@@ -39,9 +39,7 @@ def target_user(self, user_api_client, auth_user_admin):
             password=password,
             email="reset-pwd-target@test.com",
         )
-        user_obj = iam_models.User.objects.get_one(
-            filters={"uuid": user["uuid"]}
-        )
+        user_obj = iam_models.User.objects.get_one(filters={"uuid": user["uuid"]})
         admin_client.confirm_email(
             user_uuid=user_obj.uuid,
             code=str(user_obj.confirmation_code),
@@ -60,9 +58,7 @@ def test_reset_password_with_valid_code_success(
         user, _ = target_user
         admin_client = user_api_client(auth_user_admin)
 
-        user_obj = iam_models.User.objects.get_one(
-            filters={"uuid": user["uuid"]}
-        )
+        user_obj = iam_models.User.objects.get_one(filters={"uuid": user["uuid"]})
         user_obj.create_confirmation_code()
         code = str(user_obj.confirmation_code)
 
@@ -187,9 +183,7 @@ def target_user(self, user_api_client, auth_user_admin):
             password=password,
             email="send-reset-code@test.com",
         )
-        user_obj = iam_models.User.objects.get_one(
-            filters={"uuid": user["uuid"]}
-        )
+        user_obj = iam_models.User.objects.get_one(filters={"uuid": user["uuid"]})
         admin_client.confirm_email(
             user_uuid=user_obj.uuid,
             code=str(user_obj.confirmation_code),
@@ -245,9 +239,7 @@ def test_send_reset_password_code_creates_confirmation_code(
             json={"email": user["email"]},
         )
 
-        user_obj = iam_models.User.objects.get_one(
-            filters={"uuid": user["uuid"]}
-        )
+        user_obj = iam_models.User.objects.get_one(filters={"uuid": user["uuid"]})
         assert user_obj.confirmation_code is not None
 
     def test_send_reset_password_code_without_permission_forbidden(
@@ -320,9 +312,7 @@ def test_send_reset_password_code_then_reset_password_flow(
             permissions=[iam_c.PERMISSION_IAM_CLIENT_SEND_RESET_PASSWORD_CODE],
         )
 
-        user_obj = iam_models.User.objects.get_one(
-            filters={"uuid": user["uuid"]}
-        )
+        user_obj = iam_models.User.objects.get_one(filters={"uuid": user["uuid"]})
         original_secret_hash = user_obj.secret_hash
         assert user_obj.confirmation_code is None
 
@@ -331,9 +321,7 @@ def test_send_reset_password_code_then_reset_password_flow(
             json={"email": user["email"]},
         )
 
-        user_obj = iam_models.User.objects.get_one(
-            filters={"uuid": user["uuid"]}
-        )
+        user_obj = iam_models.User.objects.get_one(filters={"uuid": user["uuid"]})
         assert user_obj.confirmation_code is not None
         code = str(user_obj.confirmation_code)
         new_password = "FlowNewPass1"
@@ -346,9 +334,7 @@ def test_send_reset_password_code_then_reset_password_flow(
             json={"new_password": new_password, "code": code},
         )
 
-        user_obj = iam_models.User.objects.get_one(
-            filters={"uuid": user["uuid"]}
-        )
+        user_obj = iam_models.User.objects.get_one(filters={"uuid": user["uuid"]})
         assert user_obj.confirmation_code is None
         assert user_obj.secret_hash != original_secret_hash