Skip to content

Commit

Permalink
Fix lint issues with dask runner tests.
Browse files Browse the repository at this point in the history
  • Loading branch information
alxmrs committed Sep 5, 2022
1 parent 4a69b18 commit b96d3cd
Showing 1 changed file with 2 additions and 3 deletions.
5 changes: 2 additions & 3 deletions sdks/python/apache_beam/runners/dask/dask_runner_test.py
Original file line number Diff line number Diff line change
Expand Up @@ -17,7 +17,7 @@
import unittest

try:
import dask
import dask # pylint: disable=unused-import
except (ImportError, ModuleNotFoundError):
raise unittest.SkipTest('Dask must be installed to run tests.')

Expand All @@ -28,12 +28,11 @@
from apache_beam.testing.util import equal_to



class DaskRunnerRunPipelineTest(unittest.TestCase):
"""Test class used to introspect the dask runner via a debugger."""

def setUp(self) -> None:
self.pipeline = test_pipeline.TestPipeline(runner=DaskRunner())
self.pipeline = test_pipeline.TestPipeline(runner=DaskRunner())

def test_create(self):
with self.pipeline as p:
Expand Down

0 comments on commit b96d3cd

Please sign in to comment.