Skip to content
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

A simple plugin system #380

Merged
merged 10 commits into from
Nov 13, 2020
Merged

A simple plugin system #380

Changes from 1 commit
Commits
Show all changes
10 commits
Select commit Hold shift + click to select a range
b7a3692
a simple plugin system
roveo Nov 9, 2020
b52b92c
plugins lazy loading, specifying attribute_name in register_api, tests
roveo Nov 10, 2020
dda82ff
tests, check class of node before registering
roveo Nov 10, 2020
e4975ad
travis_wait for conda create
roveo Nov 11, 2020
0149237
fix whitespace issues
roveo Nov 11, 2020
eb93e56
fix error msg, add test
roveo Nov 11, 2020
319b9e2
add setuptools to requirements
roveo Nov 12, 2020
6c7f1f2
docs
roveo Nov 12, 2020
6e39c65
docstring for stub, register_plugin_entry_point not calling register_…
roveo Nov 12, 2020
fe0f9d9
avoid plugins overriding existing methods
roveo Nov 12, 2020
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
Prev Previous commit
Next Next commit
fix whitespace issues
  • Loading branch information
@roveo
roveo committed Nov 11, 2020
commit 01492370d4375c3b6f634e88704dc3c5c8c20683
4 changes: 2 additions & 2 deletions streamz/dataframe/tests/test_dataframes.py
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -1008,9 +1008,9 @@ def test_windowed_groupby_aggs_with_start_state(stream):
out_df1 = pd.DataFrame({'name':['Alice', 'Bob', 'Linda', 'Tom'], 'amount':[50.0, 550.0, 100.0, 150.0]})
assert_eq(output1[-1][1].reset_index(), out_df1)


def test_dir(stream):
example = pd.DataFrame({'name': [], 'amount': []})
sdf = DataFrame(stream, example=example)
assert 'name' in dir(sdf)
assert 'amount' in dir(sdf)
assert 'amount' in dir(sdf)