Add current_project helper and update examples (#645)

## Summary
- Add flyte.current_project() helper to complement the existing
flyte.current_domain() method, providing a symmetric API for resolving
the current project from runtime context or init config.
- Update webhook examples to use flyte.current_project() and
flyte.current_domain() instead of manually reading
FLYTE_INTERNAL_EXECUTION_* env vars.

## Test Plan
Run pytest tests/user_api/test_initialize.py

---------

Signed-off-by: M. Adil Fayyaz <62440954+AdilFayyaz@users.noreply.github.com>

Author: AdilFayyaz

examples/apps/run_webhook.py

@@ -34,13 +34,10 @@ async def lifespan(app: FastAPI):
     This initializes Flyte with passthrough authentication, allowing the app to
     pass user credentials from incoming requests to the Flyte control plane.
     """
-    PROJECT_NAME_ENV_VAR = "FLYTE_INTERNAL_EXECUTION_PROJECT"
-    DOMAIN_NAME_ENV_VAR = "FLYTE_INTERNAL_EXECUTION_DOMAIN"
-
     # Startup: Initialize Flyte with passthrough authentication
     await flyte.init_passthrough.aio(
-        project=os.getenv(PROJECT_NAME_ENV_VAR, None),
-        domain=os.getenv(DOMAIN_NAME_ENV_VAR, None),
+        project=flyte.current_project(),
+        domain=flyte.current_domain(),
     )
     logger.info("Initialized Flyte passthrough auth")
     yield

examples/genai/n8n/flyte_webhook_app.py

@@ -39,12 +39,9 @@
 # ---------------------------------------------------------------------------
 @asynccontextmanager
 async def lifespan(app: FastAPI):
-    PROJECT_NAME_ENV_VAR = "FLYTE_INTERNAL_EXECUTION_PROJECT"
-    DOMAIN_NAME_ENV_VAR = "FLYTE_INTERNAL_EXECUTION_DOMAIN"
-
     await flyte.init_passthrough.aio(
-        project=os.getenv(PROJECT_NAME_ENV_VAR, None),
-        domain=os.getenv(DOMAIN_NAME_ENV_VAR, None),
+        project=flyte.current_project(),
+        domain=flyte.current_domain(),
     )
     logger.info("Initialized Flyte passthrough auth")
     yield

src/flyte/__init__.py

@@ -15,7 +15,15 @@
 from ._excepthook import custom_excepthook
 from ._group import group
 from ._image import Image
-from ._initialize import current_domain, init, init_from_api_key, init_from_config, init_in_cluster, init_passthrough
+from ._initialize import (
+    current_domain,
+    current_project,
+    init,
+    init_from_api_key,
+    init_from_config,
+    init_in_cluster,
+    init_passthrough,
+)
 from ._link import Link
 from ._logging import logger
 from ._map import map
@@ -97,6 +105,7 @@ def version() -> str:
     "build_images",
     "ctx",
     "current_domain",
+    "current_project",
     "custom_context",
     "deploy",
     "get_custom_context",

src/flyte/_initialize.py

@@ -788,3 +788,32 @@ def current_domain() -> str:
             " or Call flyte.init_from_config() with a valid path to the config file",
         )
     return cfg.domain
+
+
+def current_project() -> str:
+    """
+    Returns the current project from the Runtime environment (on the cluster) or from the initialized configuration.
+    This is safe to be used during `deploy`, `run` and within `task` code.
+
+    NOTE: This will not work if you deploy a task to a project and then run it in another project.
+
+    Raises InitializationError if the configuration is not initialized or project is not set.
+    :return: The current project
+    """
+    from ._context import ctx
+
+    tctx = ctx()
+    if tctx is not None:
+        project = tctx.action.project
+        if project is not None:
+            return project
+
+    cfg = _get_init_config()
+    if cfg is None or cfg.project is None:
+        raise InitializationError(
+            "ProjectNotInitializedError",
+            "user",
+            "Project has not been initialized. Call flyte.init() with a valid project before using this function"
+            " or Call flyte.init_from_config() with a valid path to the config file",
+        )
+    return cfg.project