Skip to content

Replace dask_ml.wrappers.ParallelPostFit with custom ParallelPostFit class #832

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.

Sign up for GitHub

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

Merged
merged 17 commits into from
Oct 24, 2022
Merged

Replace dask_ml.wrappers.ParallelPostFit with custom ParallelPostFit class #832

Show file tree
Hide file tree
Changes from 1 commit
Commits
Show all changes
17 commits
Select commit Hold shift + click to select a range
7f27005
create ParallelPostFit class
sarahyurick Sep 30, 2022
a95741f
_timer
sarahyurick Sep 30, 2022
c8d901d
update create_experiment
sarahyurick Sep 30, 2022
272501b
update comment
sarahyurick Oct 4, 2022
47c9a76
migrate changes from 799
sarahyurick Oct 5, 2022
e9c3ce7
Merge branch 'main' into parallelpostfit
sarahyurick Oct 5, 2022
2195275
predict_proba_meta
sarahyurick Oct 5, 2022
0634534
fix gpu?
sarahyurick Oct 5, 2022
c75fab1
fix TypeError?
sarahyurick Oct 5, 2022
68de808
trying again
sarahyurick Oct 5, 2022
b2ca477
meta to output_meta
sarahyurick Oct 5, 2022
a44ea19
remove _timer
sarahyurick Oct 11, 2022
cc2169a
Merge branch 'main' into parallelpostfit
sarahyurick Oct 13, 2022
c26c5f4
try import sklearn
sarahyurick Oct 18, 2022
b31c355
style fix
sarahyurick Oct 18, 2022
009fd28
Update wrappers.py
sarahyurick Oct 24, 2022
ef087db
use ImportError
sarahyurick Oct 24, 2022
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
5 changes: 1 addition & 4 deletions dask_sql/physical/rel/custom/create_model.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -165,10 +165,7 @@ def convert(self, rel: "LogicalPlan", context: "dask_sql.Context") -> DataContai
model = Incremental(estimator=model)

if wrap_predict:
try:
from dask_ml.wrappers import ParallelPostFit
except ImportError: # pragma: no cover
raise ValueError("Wrapping requires dask-ml to be installed.")
from dask_sql.physical.rel.custom.wrappers import ParallelPostFit

# When `wrap_predict` is set to True we train on single partition frames
# because this is only useful for non dask distributed models
Expand Down
Loading