Add warning when warning-cap is reached

Author: berland

src/ert/scheduler/job.py

@@ -581,4 +581,8 @@ async def wait_for_file(file_path: Path, _timeout: int) -> int:
                     )
             if timeout_seconds <= 0:
                 break
+    if log_count >= max_logged_warnings:
+        logger.warning(
+            "Reached maximum number of forward model step warnings to extract"
+        )
     return timeout_seconds

tests/ert/unit_tests/scheduler/test_job.py

@@ -483,6 +483,7 @@ async def test_log_warnings_from_forward_model(
             warnings.simplefilter("error")
             await log_warnings_from_forward_model(realization, start_time - 1)
         assert emitted_warning_str not in caplog.text
+    assert "Reached maximum number" not in caplog.text
 
 
 @pytest.mark.usefixtures("use_tmpdir")
@@ -505,6 +506,7 @@ async def test_old_warnings_are_not_logged(realization, caplog, mocker):
     job_start_time = time.time() + 1  # Pretend that the job started in the future
     await log_warnings_from_forward_model(realization, job_start_time)
     assert "FutureWarning: Feature XYZ" not in caplog.text
+    assert "Reached maximum number" not in caplog.text
 
 
 @pytest.mark.usefixtures("use_tmpdir")
@@ -535,6 +537,7 @@ async def test_long_warning_from_forward_model_is_truncated(
     for line in caplog.text.splitlines():
         if "Realization 0 step foo.0 warned" in line:
             assert len(line) <= 2048 + 91
+    assert "Reached maximum number" not in caplog.text
 
 
 @pytest.mark.usefixtures("use_tmpdir")
@@ -564,6 +567,7 @@ async def test_deduplication_of_repeated_warnings_from_forward_model(
         in caplog.text
     )
     assert caplog.text.count(emitted_warning_str) == 1
+    assert "Reached maximum number" not in caplog.text
 
 
 @pytest.mark.filterwarnings("ignore:FutureWarning")
@@ -591,6 +595,7 @@ async def test_excessive_warnings_from_fm_step_can_be_capped(
         realization, start_time - 1, max_logged_warnings=log_count_cap
     )
     assert caplog.text.count("FutureWarning") == max(0, log_count_cap)
+    assert "Reached maximum number" in caplog.text
 
 
 async def test_log_warnings_from_forward_model_can_detect_files_being_created_after_delay(  # noqa: E501