fix: pyflake style

Author: jorgepiloto

tests/test_local_server.py

@@ -227,113 +227,3 @@ def test_dot_operator_server_fields_container(local_server):
     out = add.outputs.fields_container()
     assert np.allclose(out[0].scoping.ids, [1, 2])
     assert np.allclose(out[0].data, -field.data)
-
-
-def test_add_operator_server_fields_container(local_server):
-    field = dpf.core.fields_factory.create_3d_vector_field(2, server=local_server)
-    field.data = [0.0, 1.0, 2.0, 3.0, 4.0, 5.0]
-    field.scoping.ids = [1, 2]
-
-    fc = dpf.core.fields_container_factory.over_time_freq_fields_container(
-        [field, field], server=local_server
-    )
-
-    # operator with field out
-    forward = ops.utility.forward_field(field, server=local_server)
-    add = fc + forward
-    assert type(add) == ops.math.add_fc
-    out = add.outputs.fields_container()
-    assert len(out) == 2
-    assert np.allclose(out[0].scoping.ids, [1, 2])
-    assert np.allclose(out[0].data, np.array(field.data) * 2.0)
-
-    # fc + list
-    add = fc + [0.0, 1.0, 2.0]
-    assert type(add) == ops.math.add_fc
-    out = add.outputs.fields_container()
-    assert len(out) == 2
-    assert np.allclose(out[0].scoping.ids, [1, 2])
-    assert np.allclose(out[0].data, field.data + np.array([[0.0, 1.0, 2.0], [0.0, 1.0, 2.0]]))
-
-    # fc + float
-    add = fc + 1.0
-    assert type(add) == ops.math.add_fc
-    out = add.outputs.fields_container()
-    assert np.allclose(out[0].scoping.ids, [1, 2])
-    assert np.allclose(out[0].data, np.array([[1.0, 2.0, 3.0], [4.0, 5.0, 6.0]]))
-
-
-def test_minus_operator_server_fields_container(local_server):
-    field = dpf.core.fields_factory.create_3d_vector_field(2, server=local_server)
-    field.data = [0.0, 1.0, 2.0, 3.0, 4.0, 5.0]
-    field.scoping.ids = [1, 2]
-
-    fc = dpf.core.fields_container_factory.over_time_freq_fields_container(
-        [field, field], server=local_server
-    )
-
-    # operator with field out
-    forward = ops.utility.forward_field(field, server=local_server)
-    add = fc - forward
-    assert type(add) == ops.math.minus_fc
-    out = add.outputs.fields_container()
-    assert len(out) == 2
-    assert np.allclose(out[0].scoping.ids, [1, 2])
-    assert np.allclose(out[0].data, np.zeros((2, 3)))
-
-    # fc - list
-    add = fc - [0.0, 1.0, 2.0]
-    assert type(add) == ops.math.minus_fc
-    out = add.outputs.fields_container()
-    assert len(out) == 2
-    assert np.allclose(out[0].scoping.ids, [1, 2])
-    assert np.allclose(out[0].data, np.array([[0.0, 0.0, 0.0], [3.0, 3.0, 3.0]]))
-
-    # fc - float
-    add = fc - 1.0
-    assert type(add) == ops.math.minus_fc
-    out = add.outputs.fields_container()
-    assert np.allclose(out[0].scoping.ids, [1, 2])
-    assert np.allclose(out[0].data, np.array([[-1.0, 0.0, 1.0], [2.0, 3.0, 4.0]]))
-
-
-def test_dot_operator_server_fields_container(local_server):
-    field = dpf.core.fields_factory.create_3d_vector_field(2, server=local_server)
-    field.data = [0.0, 1.0, 2.0, 3.0, 4.0, 5.0]
-    field.scoping.ids = [1, 2]
-
-    fc = dpf.core.fields_container_factory.over_time_freq_fields_container(
-        [field, field], server=local_server
-    )
-
-    # fc * op
-    forward = ops.utility.forward_field(field, server=local_server)
-    add = fc * forward
-    assert type(add) == ops.math.generalized_inner_product_fc
-    out = add.outputs.fields_container()
-    assert len(out) == 2
-    assert np.allclose(out[0].scoping.ids, [1, 2])
-    assert np.allclose(out[0].data, np.array([5.0, 50.0]))
-
-    # fc * field
-    add = fc * field
-    assert type(add) == ops.math.generalized_inner_product_fc
-    out = add.outputs.fields_container()
-    assert len(out) == 2
-    assert np.allclose(out[0].scoping.ids, [1, 2])
-    assert np.allclose(out[0].data, np.array([5.0, 50.0]))
-
-    # fc * list
-    add = fc * [0.0, 1.0, 2.0]
-    assert type(add) == ops.math.generalized_inner_product_fc
-    out = add.outputs.fields_container()
-    assert len(out) == 2
-    assert np.allclose(out[0].scoping.ids, [1, 2])
-    assert np.allclose(out[0].data, np.array([5.0, 14.0]))
-
-    # fc * float
-    add = fc * -1.0
-    assert type(add) == ops.math.generalized_inner_product_fc
-    out = add.outputs.fields_container()
-    assert np.allclose(out[0].scoping.ids, [1, 2])
-    assert np.allclose(out[0].data, -field.data)

tests/test_model.py

@@ -234,7 +234,7 @@ def test_result_not_dynamic(plate_msup):
     assert len(fc) == 2
     assert np.allclose(fc.time_freq_support.time_frequencies.data, np.array([0.115, 0.125]))
     assert fc[0].unit == "Pa"
-    dis = model.results.displacement().eval()
+    model.results.displacement().eval()
     dpf.core.settings.set_dynamic_available_results_capability(True)
 
 

tests/test_multi_server.py

@@ -192,7 +192,7 @@ def test_model_cyc_support_multi_server(cyc_models):
 
 
 def test_model_displacement_multi_server(transient_models):
-    tf = transient_models[0].metadata.time_freq_support
+    transient_models[0].metadata.time_freq_support
     time_scoping = range(1, 3)
     disp = transient_models[0].results.displacement()
     disp.inputs.time_scoping(time_scoping)
@@ -226,7 +226,7 @@ def check_fc(fc, fc2):
 
 
 def test_model_stress_multi_server(transient_models):
-    tf = transient_models[0].metadata.time_freq_support
+    transient_models[0].metadata.time_freq_support
     time_scoping = range(1, 3)
     disp = transient_models[0].results.stress()
     disp.inputs.time_scoping(time_scoping)

tests/test_operator.py

@@ -573,7 +573,7 @@ def test_inputs_outputs_meshes_container(allkindofcomplexity):
 
     opsc = dpf.core.Operator("scoping::by_property")
     opsc.inputs.mesh.connect(model.metadata.meshed_region)
-    sc = opsc.outputs.mesh_scoping()
+    opsc.outputs.mesh_scoping()
 
     stress = model.results.stress()
     stress.inputs.connect(op.outputs)
@@ -838,17 +838,6 @@ def test_connect_result2(plate_msup, server_type):
     assert len(out) == len(out2)
 
 
-@pytest.mark.skipif(
-    not conftest.SERVERS_VERSION_GREATER_THAN_OR_EQUAL_TO_3_0,
-    reason="Bug in server version lower than 3.0",
-)
-def test_connect_get_output_int_list_operator(server_type):
-    d = list(range(0, 1000000))
-    op = dpf.core.operators.utility.forward(d, server=server_type)
-    d_out = op.get_output(0, dpf.core.types.vec_int)
-    assert np.allclose(d, d_out)
-
-
 @pytest.mark.skipif(
     not conftest.SERVERS_VERSION_GREATER_THAN_OR_EQUAL_TO_3_0,
     reason="Bug in server version lower than 3.0",
@@ -1166,7 +1155,7 @@ def test_get_static_spec_operator_in_proc(server_clayer):
         spec = dpf.core.Operator.operator_specification(name, server=server_clayer)
         assert len(spec.operator_name) > 0
         l = len(spec.inputs)
-        d = spec.description
+        spec.description
 
 
 @conftest.raises_for_servers_version_under("3.0")
@@ -1201,40 +1190,6 @@ def test_with_progress_operator_in_proc(allkindofcomplexity, server_clayer):
     assert len(fc) == 2
 
 
-@conftest.raises_for_servers_version_under("3.0")
-def test_list_operators(server_type_legacy_grpc):
-    l = dpf.core.dpf_operator.available_operator_names(server=server_type_legacy_grpc)
-    assert len(l) > 400
-    assert "merge::result_info" in l
-    assert "unit_convert" in l
-    assert "stream_provider" in l
-
-
-@conftest.raises_for_servers_version_under("3.0")
-def test_get_static_spec_operator(server_type_legacy_grpc):
-    l = dpf.core.dpf_operator.available_operator_names(server=server_type_legacy_grpc)
-    for i, name in enumerate(l):
-        spec = dpf.core.Operator.operator_specification(name, server=server_type_legacy_grpc)
-        assert len(spec.operator_name) > 0
-        assert len(spec.inputs) > 0
-        assert len(spec.description) > 0
-
-
-@conftest.raises_for_servers_version_under("3.0")
-def test_with_progress_operator(allkindofcomplexity, server_type):
-    model = dpf.core.Model(allkindofcomplexity, server=server_type)
-    op = model.results.stress()
-    op.inputs.read_cyclic(3)
-    opnorm = dpf.core.operators.averaging.to_nodal_fc(op, server=server_type)
-    add = dpf.core.operators.math.add_fc(opnorm, opnorm, server=server_type)
-    add2 = dpf.core.operators.math.add_fc(add, add, server=server_type)
-    add3 = dpf.core.operators.math.add_fc(add2, server=server_type)
-    add4 = dpf.core.operators.math.add_fc(add3, add3, server=server_type)
-    add4.progress_bar = True
-    fc = add4.outputs.fields_container()
-    assert len(fc) == 2
-
-
 def test_operator_specification_simple(server_type):
     spec = Specification(operator_name="U", server=server_type)
     assert "displacement" in spec.description
@@ -1318,7 +1273,7 @@ def test_delete_operator(server_type):
 
 def test_memory_outputs_operator(allkindofcomplexity):
     model = dpf.core.Model(allkindofcomplexity)
-    mesh = model.metadata.meshed_region
+    model.metadata.meshed_region
     stress_fc = model.results.stress().eqv().eval()
     assert len(stress_fc) == 2
 

tests/test_plotter.py

@@ -127,7 +127,7 @@ def test_plotter_on_fields_container_elemental(allkindofcomplexity):
     avg_op.inputs.fields_container.connect(stress.outputs.fields_container)
     fc = avg_op.outputs.fields_container()
     pl = Plotter(model.metadata.meshed_region)
-    cpos = pl.plot_contour(fc)
+    pl.plot_contour(fc)
 
 
 @pytest.mark.skipif(not HAS_PYVISTA, reason="Please install pyvista")
@@ -139,7 +139,7 @@ def test_plotter_on_fields_container_nodal(allkindofcomplexity):
     avg_op.inputs.fields_container.connect(stress.outputs.fields_container)
     fc = avg_op.outputs.fields_container()
     pl = Plotter(model.metadata.meshed_region)
-    cpos = pl.plot_contour(fc)
+    pl.plot_contour(fc)
 
 
 @pytest.mark.skipif(not HAS_PYVISTA, reason="Please install pyvista")
@@ -169,7 +169,7 @@ def test_fields_container_plot(allkindofcomplexity):
 @pytest.mark.skipif(not HAS_PYVISTA, reason="Please install pyvista")
 def test_field_elemental_plot(allkindofcomplexity):
     model = Model(allkindofcomplexity)
-    mesh = model.metadata.meshed_region
+    model.metadata.meshed_region
     stress = model.results.stress()
     stress.inputs.requested_location.connect("Elemental")
     avg_op = Operator("to_elemental_fc")
@@ -182,7 +182,7 @@ def test_field_elemental_plot(allkindofcomplexity):
 @pytest.mark.skipif(not HAS_PYVISTA, reason="Please install pyvista")
 def test_field_nodal_plot(allkindofcomplexity):
     model = Model(allkindofcomplexity)
-    mesh = model.metadata.meshed_region
+    model.metadata.meshed_region
     stress = model.results.stress()
     stress.inputs.requested_location.connect("Elemental")
     avg_op = Operator("to_nodal_fc")
@@ -200,7 +200,7 @@ def test_field_nodal_plot(allkindofcomplexity):
 @pytest.mark.skipif(not HAS_PYVISTA, reason="Please install pyvista")
 def test_field_solid_plot(allkindofcomplexity):
     model = Model(allkindofcomplexity)
-    mesh = model.metadata.meshed_region
+    model.metadata.meshed_region
     stress = model.results.stress()
     stress.inputs.requested_location.connect("Nodal")
     fc = stress.outputs.fields_container()
@@ -211,7 +211,7 @@ def test_field_solid_plot(allkindofcomplexity):
 @pytest.mark.skipif(not HAS_PYVISTA, reason="Please install pyvista")
 def test_field_shell_plot(allkindofcomplexity):
     model = Model(allkindofcomplexity)
-    mesh = model.metadata.meshed_region
+    model.metadata.meshed_region
     stress = model.results.stress()
     stress.inputs.requested_location.connect("Nodal")
     fc = stress.outputs.fields_container()
@@ -222,7 +222,7 @@ def test_field_shell_plot(allkindofcomplexity):
 @pytest.mark.skipif(not HAS_PYVISTA, reason="Please install pyvista")
 def test_field_solid_plot_scoping_nodal(multishells):
     model = core.Model(multishells)
-    mesh = model.metadata.meshed_region
+    model.metadata.meshed_region
     stress = model.results.stress()
     stress.inputs.requested_location.connect("Nodal")
     scoping = core.Scoping()
@@ -240,7 +240,7 @@ def test_field_solid_plot_scoping_nodal(multishells):
 @pytest.mark.skipif(not HAS_PYVISTA, reason="Please install pyvista")
 def test_field_shell_plot_scoping_elemental(multishells):
     model = core.Model(multishells)
-    mesh = model.metadata.meshed_region
+    model.metadata.meshed_region
     stress = model.results.stress()
     scoping = core.Scoping()
     scoping.location = "Elemental"

tests/test_plugins.py

@@ -125,7 +125,7 @@ def test_vtk(server_type, tmpdir):
     op.inputs.fields1.connect(u)
     op.inputs.mesh.connect(model.metadata.mesh_provider)
     op.inputs.directory.connect(os.path.dirname(rst_file))
-    out_path = op.eval()
+    op.eval()
     # assert out_path.result_files is not []
     # try:
     #     out_path = dpf.core.download_file(

tests/test_resultinfo.py

@@ -180,8 +180,8 @@ def test_result_info_memory_leaks(model):
         res = metadata.result_info
         # Still leaking, but maybe from the Operator.connect
         # in Metadata._load_result_info()
-        u = res.unit_system_name
-        c = res.cyclic_support
+        res.unit_system_name
+        res.cyclic_support
         # v = res.solver_version
         # date = res.solver_date
         # time = res.solver_time

tests/test_server.py

@@ -160,13 +160,13 @@ def test_available_api_types(self, server_config):
         set_server_configuration(server_config)
         server = get_or_create_server(None)
         assert has_local_server()
-        types = server.available_api_types
+        server.available_api_types
 
     def test_client(self, server_config):
         set_server_configuration(server_config)
         server = get_or_create_server(None)
         assert has_local_server()
-        client = server.client
+        server.client
 
 
 @pytest.mark.skipif(

tests/test_service.py

@@ -136,10 +136,10 @@ def test_download_with_subdir(multishells, tmpdir, server_type_remote_process):
     filename = ntpath.basename(file)
     parent_path = os.path.dirname(file)
     to_server_path = parent_path + separator + "subdir" + separator + filename
-    subdir_filepath = dpf.core.upload_file(file, to_server_path, server=server_type_remote_process)
+    dpf.core.upload_file(file, to_server_path, server=server_type_remote_process)
     folder = parent_path
 
-    out = dpf.core.download_files_in_folder(folder, tmpdir, server=server_type_remote_process)
+    dpf.core.download_files_in_folder(folder, tmpdir, server=server_type_remote_process)
     p1 = os.path.join(tmpdir, filename)
     p2 = os.path.join(tmpdir, "subdir", filename)
     # p1 = tmpdir + "/" + filename
@@ -174,9 +174,7 @@ def test_downloadinfolder_uploadinfolder(multishells, tmpdir, server_type_remote
     # download it
     new_tmpdir = os.path.join(tmpdir, "my_tmp_dir")
     os.mkdir(new_tmpdir)
-    out = dpf.core.download_files_in_folder(
-        TARGET_PATH, new_tmpdir, server=server_type_remote_process
-    )
+    dpf.core.download_files_in_folder(TARGET_PATH, new_tmpdir, server=server_type_remote_process)
     # check if the architecture of the download is ok
     path1_check = os.path.join(new_tmpdir, os.path.basename(multishells))
     path2_check = os.path.join(new_tmpdir, "subdirA", os.path.basename(multishells))
@@ -524,7 +522,7 @@ def test_server_without_context(remote_config_server_type):
 )
 @conftest.raises_for_servers_version_under("6.0")
 def test_release_dpf(server_type):
-    op = dpf.core.Operator("expansion::modal_superposition", server=server_type)
+    dpf.core.Operator("expansion::modal_superposition", server=server_type)
     server_type.release()
 
     with pytest.raises((KeyError, dpf.core.errors.DPFServerException)):
@@ -540,7 +538,7 @@ def test_license_context_manager_as_context(server_type):
     op.inputs.field(field)
     op.inputs.threshold(0.0)
     with dpf.core.LicenseContextManager(server=server_type) as lic:
-        out = op.outputs.field()
+        op.outputs.field()
         st = lic.status
 
     assert len(st) != 0
@@ -549,7 +547,7 @@ def test_license_context_manager_as_context(server_type):
     lic = dpf.core.LicenseContextManager(server=server_type)
     op.inputs.field(field)
     op.inputs.threshold(0.0)
-    out = op.outputs.field()
+    op.outputs.field()
     new_st = lic.status
     assert str(new_st) == str(st)
     lic = None
@@ -560,7 +558,7 @@ def test_license_context_manager_as_context(server_type):
     with dpf.core.LicenseContextManager(
         increment_name="ansys", license_timeout_in_seconds=1.0, server=server_type
     ) as lic:
-        out = op.outputs.field()
+        op.outputs.field()
         st = lic.status
         assert "ansys" in st
     st = lic.status