This commit is contained in:
1 parent
b38e290309
commit
8580cece27
1 file changed
+3
-3
@@ -3,7 +3,7 @@ from concurrent.futures import ThreadPoolExecutor
|
|||||||
from enum import Enum
|
from enum import Enum
|
||||||
|
|
||||||
from colony.core.network.membership import MemberRecord
|
from colony.core.network.membership import MemberRecord
|
||||||
from colony.core.storage import DEFAULT_STORAGE_FILES
|
from colony.core.storages.default import DefaultStorage
|
||||||
from colony.core.roles.gossip.role import Gossip
|
from colony.core.roles.gossip.role import Gossip
|
||||||
from colony.core.roles.role import Role
|
from colony.core.roles.role import Role
|
||||||
from colony.core.roles.unit.role import Unit
|
from colony.core.roles.unit.role import Unit
|
||||||
@@ -106,10 +106,10 @@ class Explorer(Role):
|
|||||||
self.logger.info("Snapshot updated successfully")
|
self.logger.info("Snapshot updated successfully")
|
||||||
|
|
||||||
def get_snapshot(self):
|
def get_snapshot(self):
|
||||||
return self.context.execute(VaultWarden.COMMANDS.OPEN, DEFAULT_STORAGE_FILES.COLONY_SNAPSHOT.value)
|
return self.context.execute(VaultWarden.COMMANDS.OPEN, DefaultStorage.COLONY_SNAPSHOT)
|
||||||
|
|
||||||
def set_snapshot(self, snapshot):
|
def set_snapshot(self, snapshot):
|
||||||
return self.context.execute(VaultWarden.COMMANDS.OVERWRITE, DEFAULT_STORAGE_FILES.COLONY_SNAPSHOT.value, snapshot)
|
return self.context.execute(VaultWarden.COMMANDS.OVERWRITE, DefaultStorage.COLONY_SNAPSHOT, snapshot)
|
||||||
|
|
||||||
def _hosts_to_scan(self):
|
def _hosts_to_scan(self):
|
||||||
configured = configuration.get("explorer.hosts")
|
configured = configuration.get("explorer.hosts")
|
||||||
|
|||||||
Reference in new issue
Block a user