Skip to content

Commit

Permalink
Another linting pass
Browse files Browse the repository at this point in the history
Signed-off-by: Chris Helma <[email protected]>
  • Loading branch information
chelma committed Nov 15, 2024
1 parent 168b424 commit ec091a4
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 4 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -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()
Expand All @@ -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:
Expand Down Expand Up @@ -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)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -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
Expand Down

0 comments on commit ec091a4

Please sign in to comment.