rename

Author: sanderegg

services/autoscaling/tests/unit/conftest.py

@@ -322,7 +322,7 @@ def mocked_ec2_instances_envs(
 
 
 @pytest.fixture
-def disable_dynamic_service_background_task(mocker: MockerFixture) -> None:
+def disable_autoscaling_background_task(mocker: MockerFixture) -> None:
     mocker.patch(
         "simcore_service_autoscaling.modules.auto_scaling_task.create_periodic_task",
         autospec=True,

services/autoscaling/tests/unit/test_modules_auto_scaling_computational.py

@@ -82,7 +82,7 @@ def minimal_configuration(
     local_dask_scheduler_server_envs: EnvVarsDict,
     mocked_ec2_instances_envs: EnvVarsDict,
     disabled_rabbitmq: None,
-    disable_dynamic_service_background_task: None,
+    disable_autoscaling_background_task: None,
     disable_buffers_pool_background_task: None,
     mocked_redis_server: None,
 ) -> None: ...

services/autoscaling/tests/unit/test_modules_auto_scaling_dynamic.py

@@ -201,7 +201,7 @@ def minimal_configuration(
     enabled_dynamic_mode: EnvVarsDict,
     mocked_ec2_instances_envs: EnvVarsDict,
     disabled_rabbitmq: None,
-    disable_dynamic_service_background_task: None,
+    disable_autoscaling_background_task: None,
     disable_buffers_pool_background_task: None,
     mocked_redis_server: None,
 ) -> None: ...
@@ -1075,7 +1075,7 @@ async def test_cluster_scaling_up_and_down_against_aws(
     app_with_docker_join_drained: EnvVarsDict,
     docker_swarm: None,
     disabled_rabbitmq: None,
-    disable_dynamic_service_background_task: None,
+    disable_autoscaling_background_task: None,
     disable_buffers_pool_background_task: None,
     mocked_redis_server: None,
     external_envfile_dict: EnvVarsDict,

services/autoscaling/tests/unit/test_modules_buffer_machine_core.py

@@ -59,7 +59,7 @@ def with_ec2_instance_allowed_types_env(
 @pytest.fixture
 def minimal_configuration(
     disabled_rabbitmq: None,
-    disable_dynamic_service_background_task: None,
+    disable_autoscaling_background_task: None,
     disable_buffers_pool_background_task: None,
     enabled_dynamic_mode: EnvVarsDict,
     mocked_ec2_server_envs: EnvVarsDict,
@@ -509,7 +509,7 @@ async def test_monitor_buffer_machines_terminates_unneeded_pool(
 
 @pytest.fixture
 def pre_pull_images(
-    ec2_instances_allowed_types_with_only_1_buffered: dict[InstanceTypeType, Any]
+    ec2_instances_allowed_types_with_only_1_buffered: dict[InstanceTypeType, Any],
 ) -> list[DockerGenericTag]:
     allowed_ec2_types = ec2_instances_allowed_types_with_only_1_buffered
     allowed_ec2_types_with_pre_pull_images_defined = dict(
@@ -534,7 +534,7 @@ def pre_pull_images(
 async def test_monitor_buffer_machines_against_aws(
     skip_if_external_envfile_dict: None,
     disable_buffers_pool_background_task: None,
-    disable_dynamic_service_background_task: None,
+    disable_autoscaling_background_task: None,
     disabled_rabbitmq: None,
     mocked_redis_server: None,
     external_envfile_dict: EnvVarsDict,

services/autoscaling/tests/unit/test_modules_rabbitmq.py

@@ -106,7 +106,7 @@ def test_rabbitmq_initializes(
 
 
 async def test_post_message(
-    disable_dynamic_service_background_task,
+    disable_autoscaling_background_task,
     enabled_rabbitmq: RabbitSettings,
     disabled_ec2: None,
     disabled_ssm: None,

services/autoscaling/tests/unit/test_utils_auto_scaling_core.py

@@ -89,7 +89,7 @@ async def test_associate_ec2_instances_with_nodes_with_no_correspondence(
     nodes = [node() for _ in range(10)]
     ec2_instances = [
         (
-            fake_ec2_instance_data(aws_private_dns=f"ip-10-12-32-{n+1}.internal-data")
+            fake_ec2_instance_data(aws_private_dns=f"ip-10-12-32-{n + 1}.internal-data")
             if valid_ec2_dns
             else fake_ec2_instance_data()
         )
@@ -113,7 +113,7 @@ async def test_associate_ec2_instances_with_corresponding_nodes(
     nodes = []
     ec2_instances = []
     for n in range(10):
-        host_name = f"ip-10-12-32-{n+1}"
+        host_name = f"ip-10-12-32-{n + 1}"
         nodes.append(node(Description={"Hostname": host_name}))
         ec2_instances.append(
             fake_ec2_instance_data(aws_private_dns=f"{host_name}.internal-data")
@@ -143,10 +143,9 @@ def minimal_configuration(
     disabled_rabbitmq: None,
     disabled_ec2: None,
     disabled_ssm: None,
-    disable_dynamic_service_background_task: None,
+    disable_autoscaling_background_task: None,
     mocked_redis_server: None,
-) -> None:
-    ...
+) -> None: ...
 
 
 @pytest.fixture
@@ -367,9 +366,9 @@ def test_sort_drained_nodes(
         fake_node = create_fake_node()
         assert fake_node.spec
         assert fake_node.spec.labels
-        fake_node.spec.labels[
-            _OSPARC_NODE_TERMINATION_PROCESS_LABEL_KEY
-        ] = arrow.utcnow().datetime.isoformat()
+        fake_node.spec.labels[_OSPARC_NODE_TERMINATION_PROCESS_LABEL_KEY] = (
+            arrow.utcnow().datetime.isoformat()
+        )
         fake_associated_instance = create_associated_instance(
             fake_node,
             terminateable_time=False,

services/autoscaling/tests/unit/test_utils_docker.py

@@ -921,7 +921,7 @@ async def test_find_node_with_name_with_common_prefixed_nodes(
     mocked_aiodocker = mocker.patch.object(autoscaling_docker, "nodes", autospec=True)
     mocked_aiodocker.list.return_value = [
         create_fake_node(
-            Description=NodeDescription(Hostname=f"{common_prefix}{'1'*(i+1)}")
+            Description=NodeDescription(Hostname=f"{common_prefix}{'1' * (i + 1)}")
         )
         for i in range(3)
     ]
@@ -941,7 +941,7 @@ async def test_find_node_with_smaller_name_with_common_prefixed_nodes_returns_no
     mocked_aiodocker = mocker.patch.object(autoscaling_docker, "nodes", autospec=True)
     mocked_aiodocker.list.return_value = [
         create_fake_node(
-            Description=NodeDescription(Hostname=f"{common_prefix}{'1'*(i+1)}")
+            Description=NodeDescription(Hostname=f"{common_prefix}{'1' * (i + 1)}")
         )
         for i in range(3)
     ]
@@ -1022,7 +1022,7 @@ def test_get_new_node_docker_tags(
     disabled_ssm: None,
     mocked_redis_server: None,
     enabled_dynamic_mode: EnvVarsDict,
-    disable_dynamic_service_background_task: None,
+    disable_autoscaling_background_task: None,
     app_settings: ApplicationSettings,
     fake_ec2_instance_data: Callable[..., EC2InstanceData],
 ):
@@ -1167,7 +1167,7 @@ async def test_set_node_osparc_ready(
     disabled_ssm: None,
     mocked_redis_server: None,
     enabled_dynamic_mode: EnvVarsDict,
-    disable_dynamic_service_background_task: None,
+    disable_autoscaling_background_task: None,
     app_settings: ApplicationSettings,
     autoscaling_docker: AutoscalingDocker,
     host_node: Node,
@@ -1210,7 +1210,7 @@ async def test_set_node_found_empty(
     disabled_ssm: None,
     mocked_redis_server: None,
     enabled_dynamic_mode: EnvVarsDict,
-    disable_dynamic_service_background_task: None,
+    disable_autoscaling_background_task: None,
     host_node: Node,
     autoscaling_docker: AutoscalingDocker,
 ):
@@ -1254,7 +1254,7 @@ async def test_set_node_begin_termination_process(
     disabled_ssm: None,
     mocked_redis_server: None,
     enabled_dynamic_mode: EnvVarsDict,
-    disable_dynamic_service_background_task: None,
+    disable_autoscaling_background_task: None,
     host_node: Node,
     autoscaling_docker: AutoscalingDocker,
 ):
@@ -1287,7 +1287,7 @@ async def test_attach_node(
     disabled_ssm: None,
     mocked_redis_server: None,
     enabled_dynamic_mode: EnvVarsDict,
-    disable_dynamic_service_background_task: None,
+    disable_autoscaling_background_task: None,
     app_settings: ApplicationSettings,
     autoscaling_docker: AutoscalingDocker,
     host_node: Node,

services/autoscaling/tests/unit/test_utils_rabbitmq.py

@@ -49,7 +49,7 @@
 
 
 async def test_post_task_log_message(
-    disable_dynamic_service_background_task,
+    disable_autoscaling_background_task,
     enabled_rabbitmq: RabbitSettings,
     disabled_ec2: None,
     disabled_ssm: None,
@@ -112,7 +112,7 @@ async def test_post_task_log_message(
 
 
 async def test_post_task_log_message_does_not_raise_if_service_has_no_labels(
-    disable_dynamic_service_background_task,
+    disable_autoscaling_background_task,
     enabled_rabbitmq: RabbitSettings,
     disabled_ec2: None,
     disabled_ssm: None,
@@ -143,7 +143,7 @@ async def test_post_task_log_message_does_not_raise_if_service_has_no_labels(
 
 
 async def test_post_task_progress_message(
-    disable_dynamic_service_background_task,
+    disable_autoscaling_background_task,
     enabled_rabbitmq: RabbitSettings,
     disabled_ec2: None,
     disabled_ssm: None,
@@ -209,7 +209,7 @@ async def test_post_task_progress_message(
 
 
 async def test_post_task_progress_does_not_raise_if_service_has_no_labels(
-    disable_dynamic_service_background_task,
+    disable_autoscaling_background_task,
     enabled_rabbitmq: RabbitSettings,
     disabled_ec2: None,
     disabled_ssm: None,