Run ruff

src/_ert/forward_model_runner/job.py

@@ -376,9 +376,12 @@ def _get_processtree_data(
         oom_score = int(
             Path(f"/proc/{process.pid}/oom_score").read_text(encoding="utf-8")
         )
-    with contextlib.suppress(
-        ValueError, NoSuchProcess, AccessDenied, ZombieProcess, ProcessLookupError
-    ), process.oneshot():
+    with (
+        contextlib.suppress(
+            ValueError, NoSuchProcess, AccessDenied, ZombieProcess, ProcessLookupError
+        ),
+        process.oneshot(),
+    ):
         memory_rss = process.memory_info().rss
         cpu_seconds = process.cpu_times().user
 
@@ -402,9 +405,10 @@ def _get_processtree_data(
                     if oom_score is not None
                     else oom_score_child
                 )
-            with contextlib.suppress(
-                NoSuchProcess, AccessDenied, ZombieProcess
-            ), child.oneshot():
+            with (
+                contextlib.suppress(NoSuchProcess, AccessDenied, ZombieProcess),
+                child.oneshot(),
+            ):
                 memory_rss += child.memory_info().rss
                 cpu_seconds += child.cpu_times().user
     return (memory_rss, cpu_seconds, oom_score)

src/ert/analysis/_es_update.py

@@ -189,6 +189,7 @@ def _get_observations_and_responses(
                         list(observations_and_responses["report_step"].data)
                         * len(observations_and_responses["index"].data),
                         observations_and_responses["index"].data,
+                        strict=False,
                     )
                 ]
             )
@@ -351,6 +352,7 @@ def _load_observations_and_responses(
         ens_mean_mask,
         ens_std_mask,
         indexes,
+        strict=False,
     ):
         update_snapshot.append(
             ObservationAndResponseSnapshot(

src/ert/config/gen_data_config.py

@@ -34,7 +34,9 @@ def __post_init__(self) -> None:
     @property
     def expected_input_files(self) -> List[str]:
         expected_files = []
-        for input_file, report_steps in zip(self.input_files, self.report_steps_list):
+        for input_file, report_steps in zip(
+            self.input_files, self.report_steps_list, strict=False
+        ):
             if report_steps is None:
                 expected_files.append(input_file)
             else:
@@ -130,7 +132,7 @@ def _read_file(filename: Path, report_step: int) -> xr.Dataset:
         datasets_per_name = []
 
         for name, input_file, report_steps in zip(
-            self.keys, self.input_files, self.report_steps_list
+            self.keys, self.input_files, self.report_steps_list, strict=False
         ):
             datasets_per_report_step = []
             if report_steps is None:

src/ert/config/gen_kw_config.py

@@ -290,7 +290,9 @@ def write_to_runpath(
                 f" is of size {len(self.transform_functions)}, expected {array.size}"
             )
 
-        data = dict(zip(array["names"].values.tolist(), array.values.tolist()))
+        data = dict(
+            zip(array["names"].values.tolist(), array.values.tolist(), strict=False)
+        )
 
         log10_data = {
             tf.name: math.log(data[tf.name], 10)
@@ -477,7 +479,7 @@ def _parse_transform_function_definition(
                     f"Unable to convert float number: {p}"
                 ) from e
 
-        params = dict(zip(param_names, param_floats))
+        params = dict(zip(param_names, param_floats, strict=False))
 
         return TransformFunction(
             name=t.name,

src/ert/config/observations.py

@@ -153,7 +153,7 @@ def _handle_history_observation(
                 segment_instance,
             )
         data: Dict[Union[int, datetime], Union[GenObservation, SummaryObservation]] = {}
-        for date, error, value in zip(refcase.dates, std_dev, values):
+        for date, error, value in zip(refcase.dates, std_dev, values, strict=False):
             data[date] = SummaryObservation(summary_key, summary_key, value, error)
 
         return {

src/ert/dark_storage/common.py

@@ -59,7 +59,7 @@ def gen_data_keys(ensemble: Ensemble) -> Iterator[str]:
     if gen_data_config:
         assert isinstance(gen_data_config, GenDataConfig)
         for key, report_steps in zip(
-            gen_data_config.keys, gen_data_config.report_steps_list
+            gen_data_config.keys, gen_data_config.report_steps_list, strict=False
         ):
             if report_steps is None:
                 yield f"{key}@0"

src/ert/data/_measured_data.py

@@ -141,7 +141,8 @@ def _get_data(
                 index_vals = ds.observations.coords.to_index().droplevel("report_step")
 
             index_vals = [
-                (name, data_i, i) for i, (name, data_i) in zip(data_index, index_vals)
+                (name, data_i, i)
+                for i, (name, data_i) in zip(data_index, index_vals, strict=False)
             ]
             measured_data.append(
                 pd.DataFrame(

src/ert/ensemble_evaluator/_wait_for_evaluator.py

@@ -27,13 +27,16 @@ async def attempt_connection(
 ) -> None:
     timeout = aiohttp.ClientTimeout(connect=connection_timeout)
     headers = {} if token is None else {"token": token}
-    async with aiohttp.ClientSession() as session, session.request(
-        method="get",
-        url=url,
-        ssl=get_ssl_context(cert),
-        headers=headers,
-        timeout=timeout,
-    ) as resp:
+    async with (
+        aiohttp.ClientSession() as session,
+        session.request(
+            method="get",
+            url=url,
+            ssl=get_ssl_context(cert),
+            headers=headers,
+            timeout=timeout,
+        ) as resp,
+    ):
         resp.raise_for_status()
 
 

src/ert/gui/tools/plot/style_chooser.py

@@ -199,7 +199,7 @@ def createLabelLayout(self, layout: Optional[QLayout] = None) -> QLayout:
 
         titles = ["Line style", "Width", "Marker style", "Size"]
         sizes = self.getItemSizes()
-        for title, size in zip(titles, sizes):
+        for title, size in zip(titles, sizes, strict=False):
             label = QLabel(title)
             label.setFixedWidth(size)
             layout.addWidget(label)

src/ert/resources/forward-models/res/script/ecl_run.py

@@ -167,7 +167,7 @@ def make_SLURM_machine_list(SLURM_JOB_NODELIST, SLURM_TASKS_PER_NODE):
         task_count_list += _expand_SLURM_task_count(task_count_string)
 
     host_list = []
-    for node, count in zip(nodelist, task_count_list):
+    for node, count in zip(nodelist, task_count_list, strict=False):
         host_list += [node] * count
 
     return host_list

src/ert/run_arg.py

@@ -37,7 +37,7 @@ def create_run_arguments(
     job_names = runpaths.get_jobnames(range(len(active_realizations)), iteration)
 
     for iens, (run_path, job_name, active) in enumerate(
-        zip(paths, job_names, active_realizations)
+        zip(paths, job_names, active_realizations, strict=False)
     ):
         run_args.append(
             RunArg(

src/ert/run_models/base_run_model.py

@@ -287,7 +287,9 @@ def _create_mask_from_failed_realizations(self) -> List[bool]:
             return [
                 initial and not completed
                 for initial, completed in zip(
-                    self._initial_realizations_mask, self._completed_realizations_mask
+                    self._initial_realizations_mask,
+                    self._completed_realizations_mask,
+                    strict=False,
                 )
             ]
         else:

src/ert/simulator/forward_model_status.py

@@ -118,7 +118,9 @@ def try_load(cls, path: str) -> "ForwardModelStatus":
         end_time = _deserialize_date(status_data["end_time"])
         status = cls(status_data["run_id"], start_time, end_time=end_time)
 
-        for fm_step, state in zip(fm_steps_data["jobList"], status_data["jobs"]):
+        for fm_step, state in zip(
+            fm_steps_data["jobList"], status_data["jobs"], strict=False
+        ):
             status.add_step(ForwardModelStepStatus.load(fm_step, state, path))
 
         return status

src/everest/bin/main.py

@@ -104,7 +104,9 @@ def methods_help(cls):
         pubmets.remove("methods_help")  # Current method should not show up in desc
         maxlen = max(len(m) for m in pubmets)
         docstrs = [getattr(cls, m).__doc__ for m in pubmets]
-        doclist = [m.ljust(maxlen + 1) + d for m, d in zip(pubmets, docstrs)]
+        doclist = [
+            m.ljust(maxlen + 1) + d for m, d in zip(pubmets, docstrs, strict=False)
+        ]
         return "\n".join(doclist)
 
     def run(self, args):

src/everest/bin/utils.py

@@ -232,7 +232,7 @@ def _get_progress_summary(status):
         labels = ("Waiting", "Pending", "Running", "Complete", "FAILED")
         return " | ".join(
             f"{color}{key}: {value}{Fore.RESET}"
-            for color, key, value in zip(colors, labels, status)
+            for color, key, value in zip(colors, labels, status, strict=False)
         )
 
     @classmethod

src/everest/jobs/well_tools/__init__.py

@@ -65,7 +65,7 @@ def well_set(well_data_file, new_entry_file, output_file):
         )
         raise ValueError(err_msg)
 
-    for well_entry, data_elem in zip(well_data, entry_data):
+    for well_entry, data_elem in zip(well_data, entry_data, strict=False):
         well_entry[entry_key] = data_elem
 
     with everest.jobs.io.safe_open(output_file, "w") as fout:

src/everest/simulator/simulator.py

@@ -129,6 +129,7 @@ def __call__(
                 for control_name, control_value in zip(
                     metadata.config.variables.names,  # type: ignore
                     control_values[sim_idx, :],
+                    strict=False,
                 ):
                     self._add_control(controls, control_name, control_value)
                 case_data.append((real_id, controls))

src/ieverest/widgets/batch_status_widget.py

@@ -170,7 +170,7 @@ def _set_progress(self, progress):
             wdg.setFixedSize(self._ICON_SIZE)
 
         # update the buttons
-        for wdg, info in zip(self._jobs_wdgs, progress):
+        for wdg, info in zip(self._jobs_wdgs, progress, strict=False):
             job_status = get_job_status(info)
             icon_name = self._STATUS_ICONS.get(job_status, self._DEFAULT_STATUS_ICON)
 

test-data/ert/snake_oil/jobs/snake_oil_diff.py

@@ -4,7 +4,7 @@
 
 def writeDiff(filename, vector1, vector2):
     with open(filename, "w", encoding="utf-8") as f:
-        for node1, node2 in zip(vector1, vector2):
+        for node1, node2 in zip(vector1, vector2, strict=False):
             f.write(f"{node1-node2:f}\n")
 
 

test-data/everest/math_func/jobs/adv_distance3.py

@@ -6,7 +6,7 @@
 
 
 def compute_distance_squared(p, q):
-    d = ((i - j) ** 2 for i, j in zip(p, q))
+    d = ((i - j) ** 2 for i, j in zip(p, q, strict=False))
     d = sum(d)
     return -d
 

test-data/everest/math_func/jobs/distance3.py

@@ -6,7 +6,7 @@
 
 
 def compute_distance_squared(p, q):
-    d = ((i - j) ** 2 for i, j in zip(p, q))
+    d = ((i - j) ** 2 for i, j in zip(p, q, strict=False))
     d = sum(d)
     return -d
 

tests/ert/ui_tests/cli/test_cli.py

@@ -60,9 +60,10 @@ def test_test_run_on_lsf_configuration_works_with_no_errors(tmp_path):
 )
 @pytest.mark.usefixtures("copy_poly_case")
 def test_that_the_cli_raises_exceptions_when_parameters_are_missing(mode):
-    with open("poly.ert", "r", encoding="utf-8") as fin, open(
-        "poly-no-gen-kw.ert", "w", encoding="utf-8"
-    ) as fout:
+    with (
+        open("poly.ert", "r", encoding="utf-8") as fin,
+        open("poly-no-gen-kw.ert", "w", encoding="utf-8") as fout,
+    ):
         for line in fin:
             if "GEN_KW" not in line:
                 fout.write(line)
@@ -181,9 +182,10 @@ def test_that_the_model_raises_exception_if_active_less_than_minimum_realization
     Omit testing of SingleTestRun because that executes with 1 active realization
     regardless of configuration.
     """
-    with open("poly.ert", "r", encoding="utf-8") as fin, open(
-        "poly_high_min_reals.ert", "w", encoding="utf-8"
-    ) as fout:
+    with (
+        open("poly.ert", "r", encoding="utf-8") as fin,
+        open("poly_high_min_reals.ert", "w", encoding="utf-8") as fout,
+    ):
         for line in fin:
             if "MIN_REALIZATIONS" in line:
                 fout.write("MIN_REALIZATIONS 100")
@@ -211,9 +213,10 @@ def test_that_the_model_warns_when_active_realizations_less_min_realizations():
     NUM_REALIZATIONS when running ensemble_experiment.
     A warning is issued when NUM_REALIZATIONS is higher than active_realizations.
     """
-    with open("poly.ert", "r", encoding="utf-8") as fin, open(
-        "poly_lower_active_reals.ert", "w", encoding="utf-8"
-    ) as fout:
+    with (
+        open("poly.ert", "r", encoding="utf-8") as fin,
+        open("poly_lower_active_reals.ert", "w", encoding="utf-8") as fout,
+    ):
         for line in fin:
             if "MIN_REALIZATIONS" in line:
                 fout.write("MIN_REALIZATIONS 100")
@@ -861,9 +864,10 @@ def test_that_log_is_cleaned_up_from_repeated_forward_model_steps(caplog):
     """Verify that the run model now gereneates a cleanup log when
     there are repeated forward models
     """
-    with open("poly.ert", "r", encoding="utf-8") as fin, open(
-        "poly_repeated_forward_model_steps.ert", "w", encoding="utf-8"
-    ) as fout:
+    with (
+        open("poly.ert", "r", encoding="utf-8") as fin,
+        open("poly_repeated_forward_model_steps.ert", "w", encoding="utf-8") as fout,
+    ):
         forward_model_steps = ["FORWARD_MODEL poly_eval\n"] * 5
         lines = fin.readlines() + forward_model_steps
         fout.writelines(lines)