Skip to content

Commit

Permalink
Fix imports in snapshot
Browse files Browse the repository at this point in the history
Signed-off-by: Andre Kurait <akurait@amazon.com>
  • Loading branch information
AndreKurait committed Jun 25, 2024
1 parent 2fcee46 commit fd12769
Showing 1 changed file with 5 additions and 1 deletion.
Original file line number Diff line number Diff line change
@@ -1,11 +1,13 @@
import argparse
import datetime
import logging
import subprocess
from abc import ABC, abstractmethod
from enum import Enum
from typing import Dict, Optional, Tuple

from cerberus import Validator
from console_link.models.cluster import Cluster, HttpMethod
from console_link.models.cluster import AuthMethod, Cluster, HttpMethod
from console_link.models.command_result import CommandResult

from console_link.models.schema_tools import contains_one_of
Expand Down Expand Up @@ -127,6 +129,8 @@ def __init__(self, config: Dict, source_cluster: Cluster, target_cluster: Cluste

def create(self, *args, **kwargs) -> CommandResult:
assert isinstance(self.target_cluster, Cluster)
wait = kwargs.get('wait', False)
max_snapshot_rate_mb_per_node = kwargs.get('max_snapshot_rate_mb_per_node', None)

if self.source_cluster.auth_type != AuthMethod.NO_AUTH:
raise NotImplementedError("Source cluster authentication is not supported for creating snapshots")
Expand Down

0 comments on commit fd12769

Please sign in to comment.