diff --git a/tdp/cli/commands/status/__init__.py b/tdp/cli/commands/status/__init__.py index cfacea7f..cc929b1c 100644 --- a/tdp/cli/commands/status/__init__.py +++ b/tdp/cli/commands/status/__init__.py @@ -4,7 +4,6 @@ import click from tdp.cli.commands.status.edit import edit -from tdp.cli.commands.status.generate_stales import generate_stales from tdp.cli.commands.status.show import show @@ -15,5 +14,4 @@ def status() -> None: status.add_command(edit) -status.add_command(generate_stales) status.add_command(show) diff --git a/tdp/cli/commands/status/generate_stales.py b/tdp/cli/commands/status/generate_stales.py deleted file mode 100644 index 9808905b..00000000 --- a/tdp/cli/commands/status/generate_stales.py +++ /dev/null @@ -1,66 +0,0 @@ -# Copyright 2022 TOSIT.IO -# SPDX-License-Identifier: Apache-2.0 - -from __future__ import annotations - -from typing import TYPE_CHECKING, Optional - -import click - -from tdp.cli.params import ( - collections_option, - database_dsn_option, - validate_option, - vars_option, -) -from tdp.cli.params.status import component_argument_option, service_argument_option - -if TYPE_CHECKING: - from pathlib import Path - - from sqlalchemy import Engine - - from tdp.core.collections import Collections - - -@click.command() -@service_argument_option -@component_argument_option -@collections_option -@database_dsn_option -@validate_option -@vars_option -def generate_stales( - collections: Collections, - db_engine: Engine, - validate: bool, - vars: Path, - service: Optional[str] = None, - component: Optional[str] = None, -) -> None: - """Generate stale components. - - Stales components are components that have been modified and need to be - reconfigured and/or restarted. - """ - - from tdp.cli.utils import check_services_cleanliness, print_hosted_entity_status_log - from tdp.core.variables import ClusterVariables - from tdp.dao import Dao - - cluster_variables = ClusterVariables.get_cluster_variables( - collections=collections, tdp_vars=vars, validate=validate - ) - check_services_cleanliness(cluster_variables) - - with Dao(db_engine) as dao: - stale_status_logs = dao.get_cluster_status().generate_stale_sch_logs( - cluster_variables=cluster_variables, collections=collections - ) - - dao.session.add_all(stale_status_logs) - dao.session.commit() - - print_hosted_entity_status_log( - dao.get_hosted_entity_statuses(service, component, filter_stale=True) - ) diff --git a/tests/e2e/test_tdp_status_generate_stales.py b/tests/e2e/test_tdp_status_generate_stales.py deleted file mode 100644 index c73685f0..00000000 --- a/tests/e2e/test_tdp_status_generate_stales.py +++ /dev/null @@ -1,26 +0,0 @@ -# Copyright 2022 TOSIT.IO -# SPDX-License-Identifier: Apache-2.0 - - -from click.testing import CliRunner - -from tdp.cli.commands.status.generate_stales import generate_stales -from tests.e2e.conftest import TDPInitArgs - - -def test_tdp_status_edit( - tdp_init: TDPInitArgs, -): - runner = CliRunner() - result = runner.invoke( - generate_stales, - [ - "--collection-path", - str(tdp_init.collection_path), - "--database-dsn", - tdp_init.db_dsn, - "--vars", - str(tdp_init.vars), - ], - ) - assert result.exit_code == 0, result.output