Skip to content

Refresh Distributed test for HDFS#3609

Merged
mrocklin merged 1 commit into
dask:masterfrom
jakirkham:refresh_bytes_distributed_test
Jun 14, 2018
Merged

Refresh Distributed test for HDFS#3609
mrocklin merged 1 commit into
dask:masterfrom
jakirkham:refresh_bytes_distributed_test

Conversation

@jakirkham

@jakirkham jakirkham commented Jun 13, 2018

Copy link
Copy Markdown
Member

Following up on this comment.

Updates the testing style for HDFS using a Distributed Client. This makes it more consistent with similar tests using the Distributed Client elsewhere.

cc @mrocklin

  • Tests added / passed
  • Passes flake8 dask

Comment thread dask/bytes/tests/test_hdfs.py Outdated


@pytest.mark.skipif(not distributed)
def test_distributed(hdfs):

Copy link
Copy Markdown
Member

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Thanks for doing this.

I believe that this will also need the loop pytest fixture.

Copy link
Copy Markdown
Member Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Ah, thanks for this. Didn't realize loop was a bit more magical. Do we need anything for the other functions here?

@jakirkham
jakirkham force-pushed the refresh_bytes_distributed_test branch from 59894f1 to 2d988b5 Compare June 13, 2018 19:27
@mrocklin

mrocklin commented Jun 13, 2018 via email

Copy link
Copy Markdown
Member

@jakirkham
jakirkham force-pushed the refresh_bytes_distributed_test branch 2 times, most recently from 568a293 to ba41a73 Compare June 13, 2018 21:11
@jakirkham

Copy link
Copy Markdown
Member Author

So flake8 doesn't seem to like the use of the loop variable. Any ideas?

$ flake8 dask/bytes/tests/test_hdfs.py 
dask/bytes/tests/test_hdfs.py:308:1: F811 redefinition of unused 'loop' from line 18

@mrocklin

Copy link
Copy Markdown
Member

Comment thread dask/bytes/tests/test_hdfs.py Outdated

def test_distributed(hdfs):
dist = pytest.importorskip('distributed')
@pytest.mark.skipif(not distributed)

Copy link
Copy Markdown
Member Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Seems the issue is flake8 wants to complain about this line. Though this falls out of the function having the loop variable and a decorator.

Updates the testing style for HDFS using a Distributed Client. This
makes it more consistent with similar tests using the Distributed Client
elsewhere.
@jakirkham
jakirkham force-pushed the refresh_bytes_distributed_test branch from e1e089d to e116b17 Compare June 14, 2018 05:03
@mrocklin
mrocklin merged commit fbe8f8a into dask:master Jun 14, 2018
@mrocklin

Copy link
Copy Markdown
Member

Thanks @jakirkham

@jakirkham
jakirkham deleted the refresh_bytes_distributed_test branch June 16, 2018 18:58
@jakirkham

Copy link
Copy Markdown
Member Author

Thanks.

Appears pytest wants the reason filled out for the skipif as well. This caused the Python 3.4 build to fail. Have added this in PR ( #3627 ).

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

2 participants