Drop multi processing test. Qiskit parallel_map is multiprocess based, and it copies container into each process. Saving data in the copied container just discards added data when the process finishes. For now Qiskit Experiments don't use multi processing and we don't need to care these tests immediately.

Author: nkanazawa1989

test/framework/test_data_table.py

@@ -16,7 +16,6 @@
 
 import numpy as np
 import pandas as pd
-from qiskit.tools import parallel_map
 
 from qiskit_experiments.database_service.utils import ThreadSafeDataFrame
 from qiskit_experiments.framework.analysis_result_table import AnalysisResultTable
@@ -120,76 +119,6 @@ def test_clear_container(self):
         table.clear()
         self.assertEqual(len(table), 0)
 
-    def test_multi_thread_add_entry(self):
-        """Test add entry with parallel thread access."""
-        table = TestBaseTable.TestTable()
-
-        # Mutate thread safe table in parallel thread. No race should occur.
-        parallel_map(
-            _callable_thread_local_add_entry,
-            [
-                ["x", {"value1": 0.0, "value2": 1.0, "value3": 2.0}],
-                ["y", {"value1": 3.0, "value2": 4.0, "value3": 5.0}],
-                ["z", {"value1": 6.0, "value2": 7.0, "value3": 8.0}],
-            ],
-            task_kwargs={"thread_table": table},
-        )
-        self.assertEqual(len(table), 3)
-
-        self.assertListEqual(table.loc["x"].to_list(), [0.0, 1.0, 2.0])
-        self.assertListEqual(table.loc["y"].to_list(), [3.0, 4.0, 5.0])
-        self.assertListEqual(table.loc["z"].to_list(), [6.0, 7.0, 8.0])
-
-    def test_multi_thread_add_entry_with_new_column(self):
-        """Test add entry with parallel thread access, each thread adds new column."""
-        table = TestBaseTable.TestTable()
-
-        # Mutate thread safe table in parallel thread. No race should occur.
-        parallel_map(
-            _callable_thread_local_add_entry,
-            [
-                ["x", {"value1": 0.0, "value2": 1.0, "value3": 2.0, "new_x": "x_val"}],
-                ["y", {"value1": 3.0, "value2": 4.0, "value3": 5.0, "new_y": "y_val"}],
-                ["z", {"value1": 6.0, "value2": 7.0, "value3": 8.0, "new_z": "z_val"}],
-            ],
-            task_kwargs={"thread_table": table},
-        )
-        self.assertEqual(len(table), 3)
-
-        self.assertDictEqual(
-            table.loc["x"].to_dict(),
-            {
-                "value1": 0.0,
-                "value2": 1.0,
-                "value3": 2.0,
-                "new_x": "x_val",
-                "new_y": None,
-                "new_z": None,
-            },
-        )
-        self.assertDictEqual(
-            table.loc["y"].to_dict(),
-            {
-                "value1": 3.0,
-                "value2": 4.0,
-                "value3": 5.0,
-                "new_x": None,
-                "new_y": "y_val",
-                "new_z": None,
-            },
-        )
-        self.assertDictEqual(
-            table.loc["z"].to_dict(),
-            {
-                "value1": 6.0,
-                "value2": 7.0,
-                "value3": 8.0,
-                "new_x": None,
-                "new_y": None,
-                "new_z": "z_val",
-            },
-        )
-
     def test_container_is_immutable(self):
         """Test modifying container doesn't mutate the original payload."""
         table = TestBaseTable.TestTable()