Exclude all DDL statements from Ray scheduling

Author: ccciudatu

datafusion_ray/context.py

@@ -219,15 +219,11 @@ def register_data_lake(self, table_name: str, paths: List[str]):
         self.ctx.register_datalake_table(table_name, paths)
 
     def sql(self, sql: str) -> pa.RecordBatch:
-        # TODO we should parse sql and inspect the plan rather than
-        # perform a string comparison here
-        sql_str = sql.lower()
-        if "create view" in sql_str or "drop view" in sql_str:
-            self.ctx.sql(sql)
-            return []
-
         df = self.df_ctx.sql(sql)
         execution_plan = df.execution_plan()
+        if execution_plan.display().strip() == "EmptyExec":
+            # No ray scheduling for DDL statements
+            return []
 
         graph = self.ctx.plan(execution_plan)
         final_stage_id = graph.get_final_query_stage().id()