diff --git a/spark_executor/tools/generate.py b/spark_executor/tools/generate.py index 6ce431c..029f9c0 100644 --- a/spark_executor/tools/generate.py +++ b/spark_executor/tools/generate.py @@ -36,7 +36,7 @@ def generate_job_file(code: str) -> dict[str, str]: f"PySpark code violates SQL safety policy. " f"Only SELECT and INSERT statements are allowed. " f"Found forbidden statement(s): {offenses}. " - f"Rewrite the code to use only SELECT/INSERT (or DataFrame DSL)." + f"Rewrite the code to use only SELECT/INSERT." ) path = write_job_file(code) logger.info(f"generate_job_file ok script_path={path}")