def _config_event_log_with_s3_uri()

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

• 6 lines of code
• 2 McCabe index (conditional complexity)

    def _config_event_log_with_s3_uri(self) -> None:
        if self.spark_event_logs_s3_uri:
            s3_path = re.sub("s3://", "s3a://", self.spark_event_logs_s3_uri, 1)
            with open(SPARK_DEFAULTS_CONFIG_PATH, "a") as spark_config:
                spark_config.write(CONFIG_ENABLE_EVENT_LOG + "\n")
                spark_config.write(CONFIG_EVENT_LOG_DIR_FORMAT.format(s3_path) + "\n")