[ADX-212] Make Pipeline user_id/app_id optional, default from CLI context (#1043)

* Initial plan

* Make user_id and app_id optional in Pipeline.__init__ with fallback to CLI context

Agent-Logs-Url: https://github.com/Clarifai/clarifai-python/sessions/dab343de-b778-409b-9439-1e5440d29368

Co-authored-by: rizzip <32918283+rizzip@users.noreply.github.com>

* fix: remove unnecessary is None checks

---------

Co-authored-by: copilot-swe-agent[bot] <198982749+Copilot@users.noreply.github.com>
Co-authored-by: rizzip <32918283+rizzip@users.noreply.github.com>
Co-authored-by: Peter Rizzi <peter.rizzi@clarifai.com>

Author: Copilot

clarifai/runners/pipelines/pipeline.py

@@ -19,7 +19,19 @@
 class Pipeline:
     """Code-first pipeline definition that compiles to the existing config format."""
 
-    def __init__(self, id: str, user_id: str, app_id: str, visibility: str = 'PRIVATE'):
+    def __init__(
+        self,
+        id: str,
+        user_id: Optional[str] = None,
+        app_id: Optional[str] = None,
+        visibility: str = 'PRIVATE',
+    ):
+        user_id, app_id = self._resolve_from_context(user_id, app_id)
+        if not user_id or not app_id:
+            raise ValueError(
+                "Pipeline(...) needs user_id and app_id. Pass them explicitly, "
+                "or run `clarifai login` to set them in your CLI context."
+            )
         self.id = id
         self.user_id = user_id
         self.app_id = app_id
@@ -30,6 +42,20 @@ def __init__(self, id: str, user_id: str, app_id: str, visibility: str = 'PRIVAT
         self._active = False
         self._uploaded_pipeline_version_id: Optional[str] = None
 
+    @staticmethod
+    def _resolve_from_context(user_id: Optional[str], app_id: Optional[str]) -> tuple:
+        """Fill missing user_id/app_id from the current CLI context."""
+        try:
+            from clarifai.utils.config import Config
+
+            config = Config.from_yaml()
+            ctx = config.current
+            user_id = user_id or getattr(ctx, 'user_id', None)
+            app_id = app_id or getattr(ctx, 'app_id', None)
+        except Exception:
+            pass
+        return user_id, app_id
+
     def __enter__(self):
         self._active = True
         _set_active_pipeline(self)

tests/runners/test_pipeline_dsl.py

@@ -1,4 +1,5 @@
 from pathlib import Path
+from types import SimpleNamespace
 from unittest.mock import Mock, patch
 
 import pytest
@@ -238,3 +239,34 @@ def test_step_ref_from_url_parses_versioned_pipeline_step_url():
 def test_step_ref_from_url_requires_versioned_pipeline_step_path():
     with pytest.raises(ValueError, match='versioned pipeline step URL or resource path'):
         step_ref.from_url('users/demo-user/apps/shared-app/pipeline_steps/summarize')
+
+
+def _mock_config_with_context(user_id, app_id):
+    """Return a mock Config whose .current gives a context with the given ids."""
+    ctx = SimpleNamespace(user_id=user_id, app_id=app_id)
+    config = Mock()
+    config.current = ctx
+    return config
+
+
+def test_pipeline_defaults_user_id_and_app_id_from_context():
+    config = _mock_config_with_context('ctx-user', 'ctx-app')
+    with patch('clarifai.utils.config.Config.from_yaml', return_value=config):
+        pipeline = Pipeline(id='p1')
+    assert pipeline.user_id == 'ctx-user'
+    assert pipeline.app_id == 'ctx-app'
+
+
+def test_pipeline_explicit_args_override_context():
+    config = _mock_config_with_context('ctx-user', 'ctx-app')
+    with patch('clarifai.utils.config.Config.from_yaml', return_value=config):
+        pipeline = Pipeline(id='p2', user_id='explicit-user', app_id='explicit-app')
+    assert pipeline.user_id == 'explicit-user'
+    assert pipeline.app_id == 'explicit-app'
+
+
+def test_pipeline_raises_without_context_or_explicit_args():
+    config = _mock_config_with_context(None, None)
+    with patch('clarifai.utils.config.Config.from_yaml', return_value=config):
+        with pytest.raises(ValueError, match='clarifai login'):
+            Pipeline(id='p3')