diff --git a/TrafficCapture/dockerSolution/src/main/docker/migrationConsole/lib/console_link/console_link/models/backfill_rfs.py b/TrafficCapture/dockerSolution/src/main/docker/migrationConsole/lib/console_link/console_link/models/backfill_rfs.py index 9becc7c14..ef23ee334 100644 --- a/TrafficCapture/dockerSolution/src/main/docker/migrationConsole/lib/console_link/console_link/models/backfill_rfs.py +++ b/TrafficCapture/dockerSolution/src/main/docker/migrationConsole/lib/console_link/console_link/models/backfill_rfs.py @@ -161,7 +161,6 @@ def archive(self, *args, archive_dir_path: str = None, archive_file_name: str = return CommandResult(False, WorkingIndexDoesntExist(WORKING_STATE_INDEX)) return CommandResult(False, e) - def get_status(self, deep_check: bool, *args, **kwargs) -> CommandResult: logger.info(f"Getting status of RFS backfill, with {deep_check=}") instance_statuses = self.ecs_client.get_instance_statuses() @@ -184,7 +183,6 @@ def get_status(self, deep_check: bool, *args, **kwargs) -> CommandResult: return CommandResult(True, (BackfillStatus.STARTING, status_string)) return CommandResult(True, (BackfillStatus.STOPPED, status_string)) - def _get_detailed_status(self) -> Optional[str]: # Check whether the working state index exists. If not, we can't run queries. try: @@ -253,7 +251,7 @@ def get_working_state_index_backup_path(archive_dir_path: str = None, archive_fi return os.path.join(backup_dir, file_name) -def backup_working_state_index(cluster: Cluster, index_name:str, backup_path: str): +def backup_working_state_index(cluster: Cluster, index_name: str, backup_path: str): # Ensure the backup directory exists backup_dir = os.path.dirname(backup_path) os.makedirs(backup_dir, exist_ok=True) diff --git a/TrafficCapture/dockerSolution/src/main/docker/migrationConsole/lib/console_link/tests/test_backfill.py b/TrafficCapture/dockerSolution/src/main/docker/migrationConsole/lib/console_link/tests/test_backfill.py index 81816fbb5..dde324838 100644 --- a/TrafficCapture/dockerSolution/src/main/docker/migrationConsole/lib/console_link/tests/test_backfill.py +++ b/TrafficCapture/dockerSolution/src/main/docker/migrationConsole/lib/console_link/tests/test_backfill.py @@ -11,7 +11,7 @@ from console_link.models.backfill_base import Backfill, BackfillStatus from console_link.models.backfill_osi import OpenSearchIngestionBackfill from console_link.models.backfill_rfs import (DockerRFSBackfill, ECSRFSBackfill, RfsWorkersInProgress, - WorkingIndexDoesntExist) + WorkingIndexDoesntExist) from console_link.models.ecs_service import ECSService, InstanceStatuses from console_link.models.factories import UnsupportedBackfillTypeError, get_backfill from tests.utils import create_valid_cluster