-
Notifications
You must be signed in to change notification settings - Fork 10
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Feature/remove session context #14
Feature/remove session context #14
Conversation
45364be
to
89eb0a1
Compare
…rnment. Also since adding the docker ignore, we can just copy in the entire directory that remains.
@@ -176,7 +175,7 @@ def execute_query_partition( | |||
*input_partitions: list[pa.RecordBatch], | |||
) -> Iterable[pa.RecordBatch]: | |||
start_time = time.time() | |||
plan = datafusion_ray.deserialize_execution_plan(plan_bytes) | |||
# plan = datafusion_ray.deserialize_execution_plan(plan_bytes) |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
nit: can we remove this line now?
// println!("Planning {}", sql); | ||
// let df = wait_for_future(py, self.ctx.sql(sql))?; | ||
// let py_df = self.run_sql(sql, py)?; | ||
// let py_plan = py_df.call_method0(py, "execution_plan")?; | ||
// let py_plan = py_plan.bind(py); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
can we remove this commented out code?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Amazing. Thank you @timsaucer
Sorry I missed those commented lines. I’m out for the weekend so I’ll push the edits Monday. |
I think is fine to fix those in a follow up PR |
This PR removes the
datafusion-python
SessionContext from being owned byContext
indatafusion-ray
. This allows the user to use all of the features already existing indatafusion-python
.I have tested it against the example
tips.py