Skip to content

Commit e4be0ad

Browse files
committed
fix stuffs
1 parent 0fd79a9 commit e4be0ad

File tree

2 files changed

+7
-4
lines changed

2 files changed

+7
-4
lines changed

subvortex/auto_upgrader/src/migrations/redis_migrations.py

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -187,6 +187,13 @@ async def _downgrade(self, database, revisions, current_version):
187187
self.applied_revisions.append(rev)
188188

189189
def _create_redis_instance(self):
190+
password = os.getenv("SUBVORTEX_DATABASE_PASSWORD")
191+
if not password:
192+
btul.logging.warning(
193+
f"No password configured. It is recommended to have one.",
194+
prefix=sauc.SV_LOGGER_NAME,
195+
)
196+
190197
return aioredis.StrictRedis(
191198
host=os.getenv("SUBVORTEX_DATABASE_HOST", "localhost"),
192199
port=int(os.getenv("SUBVORTEX_DATABASE_PORT", 6379)),

subvortex/auto_upgrader/src/orchestrator.py

Lines changed: 0 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -481,7 +481,6 @@ def _rollback_services(self):
481481
continue
482482

483483
# Execute the setup
484-
print("TEARDOWN SERVICE")
485484
self._execute_teardown(service=service)
486485

487486
async def _rollout_migrations(self):
@@ -560,7 +559,6 @@ def _rollback_stop_current_services(self, service_filter: Callable = None):
560559
if not current_service:
561560
continue
562561

563-
print(f"START SERVICE: {current_service}")
564562
self._execute_start(service=current_service)
565563

566564
def _switch_services(self):
@@ -628,7 +626,6 @@ def _rollback_start_latest_services(self, service_filter: Callable = None):
628626
if service_filter and not service_filter(service):
629627
continue
630628

631-
print(f"STOP SERVICE: {service}")
632629
self._execute_stop(service=service)
633630

634631
def _prune_services(self):
@@ -657,7 +654,6 @@ def _rollback_prune_services(self):
657654
continue
658655

659656
# Execute the setup
660-
print(f"SETUP SERVICE: {service}")
661657
self._execute_setup(service=service)
662658

663659
def _remove_services(self):

0 commit comments

Comments
 (0)