Cleanups
This commit is contained in:
@@ -18,7 +18,7 @@ class SessionFileHandler(StreamHandler):
|
||||
|
||||
def create_dir(self) -> None:
|
||||
"""Create the log dir if needed"""
|
||||
self.filename.parent.mkdir(exist_ok=True)
|
||||
self.filename.parent.mkdir(exist_ok=True, parents=True)
|
||||
|
||||
def rotate_file(self, file: Path):
|
||||
"""Rotate a file's number suffix and remove it if it's too old"""
|
||||
|
||||
@@ -1,10 +1,10 @@
|
||||
import logging
|
||||
import logging.config as logging_dot_config
|
||||
import os
|
||||
import sys
|
||||
import subprocess
|
||||
import sys
|
||||
|
||||
from src import shared
|
||||
from src import shared # pylint: disable=no-name-in-module
|
||||
|
||||
|
||||
def setup_logging():
|
||||
@@ -16,7 +16,7 @@ def setup_logging():
|
||||
app_log_level = os.environ.get("LOGLEVEL", profile_app_log_level).upper()
|
||||
lib_log_level = os.environ.get("LIBLOGLEVEL", profile_lib_log_level).upper()
|
||||
|
||||
log_filename = shared.data_dir / "cartridges" / "logs" / "cartridges.log.xz"
|
||||
log_filename = shared.cache_dir / "cartridges" / "logs" / "cartridges.log.xz"
|
||||
|
||||
config = {
|
||||
"version": 1,
|
||||
@@ -35,7 +35,7 @@ def setup_logging():
|
||||
"formatter": "file_formatter",
|
||||
"level": "DEBUG",
|
||||
"filename": log_filename,
|
||||
"backup_count": 2,
|
||||
"backup_count": 3,
|
||||
},
|
||||
"app_console_handler": {
|
||||
"class": "logging.StreamHandler",
|
||||
|
||||
@@ -110,5 +110,6 @@ class Manager:
|
||||
self, game: Game, additional_data: dict, callback: Callable[["Manager"], Any]
|
||||
) -> None:
|
||||
"""Pass the game through the manager"""
|
||||
# TODO: connect to signals here
|
||||
self.execute_resilient_manager_logic(game, additional_data)
|
||||
callback(self)
|
||||
|
||||
@@ -40,12 +40,12 @@ class Pipeline(GObject.Object):
|
||||
def blocked(self) -> set[Manager]:
|
||||
"""Get the managers that cannot run because their dependencies aren't done"""
|
||||
blocked = set()
|
||||
for manager_a in self.waiting:
|
||||
for manager_b in self.not_done:
|
||||
if manager_a == manager_b:
|
||||
for waiting in self.waiting:
|
||||
for not_done in self.not_done:
|
||||
if waiting == not_done:
|
||||
continue
|
||||
if type(manager_b) in manager_a.run_after:
|
||||
blocked.add(manager_a)
|
||||
if type(not_done) in waiting.run_after:
|
||||
blocked.add(waiting)
|
||||
return blocked
|
||||
|
||||
@property
|
||||
|
||||
Reference in New Issue
Block a user