Skip to content

Commit

Permalink
Update noqa issues again
Browse files Browse the repository at this point in the history
  • Loading branch information
drobison00 committed Jun 14, 2023
1 parent 7477fc9 commit caef945
Showing 1 changed file with 3 additions and 13 deletions.
16 changes: 3 additions & 13 deletions python/tests/test_segment_modules.py
Original file line number Diff line number Diff line change
Expand Up @@ -27,7 +27,6 @@


def test_py_end_to_end():

def gen_data_1():
yield True
yield False
Expand Down Expand Up @@ -57,7 +56,6 @@ def gen_data_2():
#

def init_wrapper(builder: mrc.Builder):

global packets_1, packets_2, packets_3
packets_1, packets_2, packets_3 = 0, 0, 0

Expand Down Expand Up @@ -118,7 +116,6 @@ def on_complete():


def test_py_constructor():

config = {"config_key_1": True}

registry = mrc.ModuleRegistry
Expand All @@ -137,15 +134,13 @@ def test_py_constructor():


def test_py_module_initialization():

def gen_data():
yield True
yield False
yield True
yield True

def init_wrapper(builder: mrc.Builder):

def on_next(input):
pass

Expand Down Expand Up @@ -204,7 +199,6 @@ def on_complete():


def test_py_module_as_source():

def init_wrapper(builder: mrc.Builder):
global packet_count
packet_count = 0
Expand Down Expand Up @@ -241,7 +235,6 @@ def on_complete():


def test_py_module_as_sink():

def gen_data():
for i in range(0, 43):
yield True
Expand Down Expand Up @@ -272,7 +265,6 @@ def init_wrapper(builder: mrc.Builder):


def test_py_module_chaining():

def init_wrapper(builder: mrc.Builder):
global packet_count
packet_count = 0
Expand Down Expand Up @@ -312,7 +304,6 @@ def on_complete():


def test_py_module_nesting():

def init_wrapper(builder: mrc.Builder):
global packet_count
packet_count = 0
Expand Down Expand Up @@ -348,7 +339,6 @@ def on_complete():


def test_py_modules_dont_overwrite():

def init_wrapper(builder: mrc.Builder):
global packet_count
packet_count = 0
Expand All @@ -368,8 +358,8 @@ def on_complete():

# Make sure we can't re-register the same name
with pytest.raises(RuntimeError):
this_should_fail = builder.load_module("NestedModule", "mrc_unittest", "ModuleNestingTest_mod1",
{}) # noqa: E841
this_should_fail = builder.load_module("NestedModule", "mrc_unittest", "ModuleNestingTest_mod1", # noqa
{}) # noqa

nested_mod2 = builder.load_module("NestedModule", "mrc_unittest", "ModuleNestingTest_mod2", {})
nested_sink = builder.make_sink("nested_sink", on_next, on_error, on_complete)
Expand All @@ -392,7 +382,7 @@ def on_complete():
assert packet_count == 8


if (__name__ in ("__main__", )):
if (__name__ in ("__main__",)):
test_py_end_to_end()
test_py_module_as_source()
test_py_module_as_sink()
Expand Down

0 comments on commit caef945

Please sign in to comment.