fix: fail fast on Cinema 4D license failures

Signed-off-by: Karthik Bekal Pattathana <133984042+karthikbekalp@users.noreply.github.com>

Author: karthikbekalp

src/deadline/cinema4d_adaptor/Cinema4DAdaptor/adaptor.py

@@ -314,6 +314,18 @@ def _get_regex_callbacks(self) -> list[RegexCallback]:
                 )
             )
 
+            license_error_regexes = [
+                re.compile(r".*IsFloating query failed.*", re.IGNORECASE),
+                re.compile(r".*No license found\..*\(2030\).*", re.IGNORECASE),
+                re.compile(r".*No available licenses to choose\..*", re.IGNORECASE),
+            ]
+            callback_list.append(
+                RegexCallback(
+                    license_error_regexes,
+                    self._handle_license_error,
+                )
+            )
+
             self._regex_callbacks = callback_list
         return self._regex_callbacks
 
@@ -404,6 +416,19 @@ def _handle_nvidia_driver_error(self, match: re.Match) -> None:
         )
         self._exc_info = RuntimeError(message)
 
+    def _handle_license_error(self, match: re.Match) -> None:
+        """Handle a fatal Cinema 4D licensing failure."""
+        message = (
+            "Cinema 4D failed to acquire a license.\n"
+            "If you are using bring your own license (BYOL), check your license configuration "
+            "and availability.\n"
+            "If you are using usage-based licensing (UBL) from AWS Deadline Cloud and need a "
+            "higher 'License sessions per license endpoint' limit, contact the AWS Deadline Cloud "
+            "team to request an increase.\n"
+            f"Error: {match.group(0)}"
+        )
+        self._exc_info = RuntimeError(message)
+
     def _add_deadline_openjd_paths(self) -> None:
         # Add the openjd namespace directory to PYTHONPATH, so that adaptor_runtime_client
         # will be available directly to the adaptor client.

test/unit/deadline_adaptor_for_cinema4d/Cinema4DAdaptor/test_adaptor.py

@@ -6,6 +6,7 @@
 # the same Cinema4DAdaptor action queue, which can cause race conditions and
 # test failures when tests run in parallel across multiple workers.
 import json
+import logging
 from pathlib import Path
 from unittest.mock import Mock, PropertyMock, patch
 
@@ -364,6 +365,64 @@ def test__wait_for_socket(
         # THEN
         assert mock_sleep.call_count == 3
 
+    @pytest.mark.parametrize(
+        "license_error",
+        [
+            "17:44:34 Error running authentication: IsFloating query failed.",
+            "17:44:34 No license found. [.(2030)]",
+            "18:38:54 No available licenses to choose.",
+        ],
+    )
+    def test_license_failure_from_stdout_interrupts_startup(
+        self, init_data: dict, license_error: str
+    ) -> None:
+        """Tests that a licensing prompt fails startup without waiting for the timeout."""
+        # General error checking is optional, but a licensing prompt cannot recover
+        # without interactive input and must always stop the worker.
+        init_data["activate_error_checking"] = "0"
+        adaptor = Cinema4DAdaptor(init_data)
+        expected_error = (
+            "Cinema 4D failed to acquire a license.\n"
+            "If you are using bring your own license (BYOL), check your license configuration "
+            "and availability.\n"
+            "If you are using usage-based licensing (UBL) from AWS Deadline Cloud and need a "
+            "higher 'License sessions per license endpoint' limit, contact the AWS Deadline Cloud "
+            "team to request an increase.\n"
+            f"Error: {license_error}"
+        )
+
+        def emit_license_error(*args, **kwargs):
+            kwargs["stdout_handler"].emit(
+                logging.LogRecord(
+                    name="cinema4d",
+                    level=logging.ERROR,
+                    pathname="",
+                    lineno=0,
+                    msg=license_error,
+                    args=(),
+                    exc_info=None,
+                )
+            )
+            process = Mock()
+            process.is_running = True
+            return process
+
+        with (
+            patch.object(adaptor, "_initialize_maxon_assets_db_connection"),
+            patch.object(adaptor, "_start_cinema4d_server_thread"),
+            patch.object(adaptor, "_populate_action_queue"),
+            patch(
+                "deadline.cinema4d_adaptor.Cinema4DAdaptor.adaptor.LoggingSubprocess",
+                side_effect=emit_license_error,
+            ),
+            patch("time.sleep") as mock_sleep,
+            pytest.raises(RuntimeError) as exc_info,
+        ):
+            adaptor.on_start()
+
+        assert str(exc_info.value) == expected_error
+        mock_sleep.assert_not_called()
+
 
 @pytest.mark.xdist_group(name="adaptor_tests")
 class TestCinema4DAdaptor_on_run: