fix: add force flag for import testing (#864)

doc/conf.py

@@ -1,4 +1,5 @@
 """Sphinx configuration."""
+
 import datetime
 
 import pkg_resources

src/braket/aws/aws_device.py

@@ -332,9 +332,11 @@ def _get_regional_device_session(self, session: AwsSession) -> AwsSession:
             self._populate_properties(region_session)
             return region_session
         except ClientError as e:
-            raise ValueError(f"'{self._arn}' not found") if e.response["Error"][
-                "Code"
-            ] == "ResourceNotFoundException" else e
+            raise (
+                ValueError(f"'{self._arn}' not found")
+                if e.response["Error"]["Code"] == "ResourceNotFoundException"
+                else e
+            )
 
     def _get_non_regional_device_session(self, session: AwsSession) -> AwsSession:
         current_region = session.region

src/braket/aws/aws_quantum_job.py

@@ -609,9 +609,11 @@ def _initialize_regional_device_session(
             aws_session.get_device(device)
             return aws_session
         except ClientError as e:
-            raise ValueError(f"'{device}' not found.") if e.response["Error"][
-                "Code"
-            ] == "ResourceNotFoundException" else e
+            raise (
+                ValueError(f"'{device}' not found.")
+                if e.response["Error"]["Code"] == "ResourceNotFoundException"
+                else e
+            )
 
     @staticmethod
     def _initialize_non_regional_device_session(

src/braket/aws/aws_quantum_task.py

@@ -534,9 +534,9 @@ def _download_result(
             "has_reservation_arn": self._has_reservation_arn_from_metadata(current_metadata),
         }
         try:
-            task_event[
-                "execution_duration"
-            ] = self._result.additional_metadata.simulatorMetadata.executionDuration
+            task_event["execution_duration"] = (
+                self._result.additional_metadata.simulatorMetadata.executionDuration
+            )
         except AttributeError:
             pass
         broadcast_event(_TaskCompletionEvent(**task_event))

src/braket/circuits/gate.py

@@ -180,9 +180,11 @@ def _to_openqasm(
             for state, group in groupby(control_basis_state.as_tuple):
                 modifier_name = "neg" * (not state) + "ctrl"
                 control_modifiers += [
-                    f"{modifier_name}"
-                    if (num_control := len(list(group))) == 1
-                    else f"{modifier_name}({num_control})"
+                    (
+                        f"{modifier_name}"
+                        if (num_control := len(list(group))) == 1
+                        else f"{modifier_name}({num_control})"
+                    )
                 ]
             control_modifiers.append("")
             qubits = control_qubits + target_qubits

src/braket/pulse/pulse_sequence.py

@@ -387,10 +387,10 @@ def _parse_from_calibration_schema(
                                 argument_value.update(QubitSet(int(argument["value"])))
                             instr_args["qubits_or_frames"] = argument_value
                         elif argument["name"] in instr_args_keys:
-                            instr_args[
-                                argument["name"]
-                            ] = calibration_sequence._parse_arg_from_calibration_schema(
-                                argument, waveforms, frames
+                            instr_args[argument["name"]] = (
+                                calibration_sequence._parse_arg_from_calibration_schema(
+                                    argument, waveforms, frames
+                                )
                             )
                 else:
                     instr_args["qubits_or_frames"] = []

src/braket/quantum_information/pauli_string.py

@@ -101,9 +101,11 @@ def weight_n_substrings(self, weight: int) -> tuple[PauliString, ...]:
         substrings = []
         for indices in itertools.combinations(self._nontrivial, weight):
             factors = [
-                self._nontrivial[qubit]
-                if qubit in set(indices).intersection(self._nontrivial)
-                else "I"
+                (
+                    self._nontrivial[qubit]
+                    if qubit in set(indices).intersection(self._nontrivial)
+                    else "I"
+                )
                 for qubit in range(self._qubit_count)
             ]
             substrings.append(

test/unit_tests/braket/aws/common_test_utils.py

@@ -353,12 +353,14 @@ def _create_task_args_and_kwargs(
     create_kwargs = extra_kwargs or {}
     create_kwargs.update(
         {
-            "poll_timeout_seconds": poll_timeout_seconds
-            if poll_timeout_seconds is not None
-            else default_poll_timeout,
-            "poll_interval_seconds": poll_interval_seconds
-            if poll_interval_seconds is not None
-            else default_poll_interval,
+            "poll_timeout_seconds": (
+                poll_timeout_seconds if poll_timeout_seconds is not None else default_poll_timeout
+            ),
+            "poll_interval_seconds": (
+                poll_interval_seconds
+                if poll_interval_seconds is not None
+                else default_poll_interval
+            ),
             "inputs": inputs,
             "gate_definitions": gate_definitions,
             "reservation_arn": reservation_arn,

test/unit_tests/braket/test_imports.py

@@ -13,7 +13,7 @@ def test_for_import_cycles():
     # parameterized version wasn't able to correctly detect some circular imports when running tox.
     modules = get_modules_to_test()
     processes = []
-    multiprocessing.set_start_method("spawn")
+    multiprocessing.set_start_method("spawn", force=True)
     for module in modules:
         # We create a separate process to make sure the imports do not interfere with each-other.
         process = multiprocessing.Process(target=import_module, args=(module,))