fix: sanitize compute default version ref

Author: guillaq

workflowai/core/client/_client.py

@@ -44,8 +44,10 @@ def _compute_default_version_reference() -> VersionReference:
     if version in {"dev", "staging", "production"}:
         return version  # pyright: ignore [reportReturnType]
 
-    if isinstance(version, int):
-        return version
+    try:
+        return int(version)
+    except ValueError:
+        pass
 
     _logger.warning("Invalid default version: %s", version)
 

workflowai/core/client/_client_test.py

@@ -1,6 +1,6 @@
 import importlib.metadata
 import json
-from typing import AsyncIterator
+from typing import Any, AsyncIterator
 from unittest.mock import AsyncMock, patch
 
 import pytest
@@ -9,7 +9,7 @@
 from tests.models.hello_task import HelloTask, HelloTaskInput, HelloTaskNotOptional, HelloTaskOutput
 from tests.utils import fixtures_json
 from workflowai.core.client import Client
-from workflowai.core.client._client import WorkflowAIClient
+from workflowai.core.client._client import WorkflowAIClient, _compute_default_version_reference
 from workflowai.core.domain.task_run import Run
 
 
@@ -261,3 +261,12 @@ def fn(task_input: HelloTaskInput) -> AsyncIterator[HelloTaskOutput]: ...
             HelloTaskOutput(message="hello"),
             HelloTaskOutput(message="hello"),
         ]
+
+
+@pytest.mark.parametrize(
+    ("env_var", "expected"),
+    [("p", "production"), ("production", "production"), ("dev", "dev"), ("staging", "staging"), ("1", 1)],
+)
+def test_compute_default_version_reference(env_var: str, expected: Any):
+    with patch.dict("os.environ", {"WORKFLOWAI_DEFAULT_VERSION": env_var}):
+        assert _compute_default_version_reference() == expected