def __init__()

in src/smspark/spark_executor_logs_watcher.py [0:0]

• 3 lines of code
• 1 McCabe index (conditional complexity)

    def __init__(self, log_dir: str = "/var/log/yarn") -> None:
        """Initialize the executor log watcher."""
        Thread.__init__(self)
        self.log_dir = log_dir