Infer sandbox app if spawned from inside container

modal/_container_io_manager.py

@@ -442,6 +442,7 @@ async def get_app_objects(self) -> RunningApp:
             environment_name=self._environment_name,
             tag_to_object_id=tag_to_object_id,
             object_handle_metadata=object_handle_metadata,
+            client=self._client,
         )
 
     async def get_serialized_function(self) -> Tuple[Optional[Any], Optional[Callable[..., Any]]]:

modal/app.py

@@ -124,6 +124,7 @@ def foo():
     """
 
     _all_apps: ClassVar[Dict[Optional[str], List["_App"]]] = {}
+    _container_app: ClassVar[Optional[RunningApp]] = None
 
     _name: Optional[str]
     _description: Optional[str]
@@ -212,6 +213,10 @@ def description(self) -> Optional[str]:
         """The App's `name`, if available, or a fallback descriptive identifier."""
         return self._description
 
+    @property
+    def client(self) -> Optional[_Client]:
+        return self._client
+
     def set_description(self, description: str):
         self._description = description
 
@@ -429,6 +434,8 @@ def _init_container(self, client: _Client, running_app: RunningApp):
         self._running_app = running_app
         self._client = client
 
+        _App._container_app = running_app
+
         # Hydrate objects on app
         for tag, object_id in running_app.tag_to_object_id.items():
             if tag in self._indexed_objects:

modal/runner.py

@@ -57,7 +57,7 @@ async def _init_local_app_existing(client: _Client, existing_app_id: str) -> Run
     obj_resp = await retry_transient_errors(client.stub.AppGetObjects, obj_req)
     app_page_url = f"https://modal.com/apps/{existing_app_id}"  # TODO (elias): this should come from the backend
     object_ids = {item.tag: item.object.object_id for item in obj_resp.items}
-    return RunningApp(existing_app_id, app_page_url=app_page_url, tag_to_object_id=object_ids)
+    return RunningApp(existing_app_id, app_page_url=app_page_url, tag_to_object_id=object_ids, client=client)
 
 
 async def _init_local_app_new(
@@ -76,6 +76,7 @@ async def _init_local_app_new(
     logger.debug(f"Created new app with id {app_resp.app_id}")
     return RunningApp(
         app_resp.app_id,
+        client=client,
         app_page_url=app_resp.app_page_url,
         app_logs_url=app_resp.app_logs_url,
         environment_name=environment_name,

modal/running_app.py

@@ -4,6 +4,8 @@
 
 from google.protobuf.message import Message
 
+from .client import _Client
+
 
 @dataclass
 class RunningApp:
@@ -14,3 +16,4 @@ class RunningApp:
     tag_to_object_id: Dict[str, str] = field(default_factory=dict)
     object_handle_metadata: Dict[str, Optional[Message]] = field(default_factory=dict)
     interactive: bool = False
+    client: Optional[_Client] = None

modal/sandbox.py

@@ -26,6 +26,7 @@
 from .mount import _Mount
 from .network_file_system import _NetworkFileSystem, network_file_system_mount_protos
 from .object import _Object
+from .running_app import RunningApp
 from .scheduler_placement import SchedulerPlacement
 from .secret import _Secret
 
@@ -183,6 +184,8 @@ async def create(
         client: Optional[_Client] = None,
         _experimental_gpus: Sequence[GPU_T] = [],
     ) -> "_Sandbox":
+        from .app import _App
+
         if environment_name is None:
             environment_name = config.get("environment")
 
@@ -208,12 +211,15 @@ async def create(
             _experimental_scheduler_placement=_experimental_scheduler_placement,
             _experimental_gpus=_experimental_gpus,
         )
+
+        inferred_app: Union[_App, RunningApp] = app or _App._container_app
+
         if client is None:
-            if app and app._client:
-                client = app._client
+            if inferred_app and inferred_app.client:
+                client = inferred_app.client
             else:
                 client = await _Client.from_env()
-        app_id: Optional[str] = app.app_id if app else None
+        app_id: Optional[str] = inferred_app.app_id if inferred_app else None
         resolver = Resolver(client, environment_name=environment_name, app_id=app_id)
         await resolver.load(obj)
         return obj

test/conftest.py

@@ -192,6 +192,7 @@ def __init__(self, blob_host, blobs):
         self.volume_reloads: Dict[str, int] = defaultdict(lambda: 0)
 
         self.sandbox_defs = []
+        self.sandbox_app_id = None
         self.sandbox: asyncio.subprocess.Process = None
         self.sandbox_result: Optional[api_pb2.GenericResult] = None
 
@@ -1181,6 +1182,7 @@ async def SandboxCreate(self, stream):
             stdin=asyncio.subprocess.PIPE,
         )
 
+        self.sandbox_app_id = request.app_id
         self.sandbox_defs.append(request.definition)
 
         await stream.send_message(api_pb2.SandboxCreateResponse(sandbox_id="sb-123"))

test/container_test.py

@@ -2065,3 +2065,9 @@ def test_max_concurrency(servicer):
 
     outputs = [deserialize(item.result.data, ret.client) for item in ret.items]
     assert n_inputs in outputs
+
+
+@skip_github_non_linux
+def test_sandbox_infers_app(servicer, event_loop):
+    _run_container(servicer, "test.supports.sandbox", "spawn_sandbox")
+    assert servicer.sandbox_app_id == "ap-1"

test/supports/sandbox.py

@@ -0,0 +1,9 @@
+# Copyright Modal Labs 2024
+import modal
+
+app = modal.App()
+
+
+@app.function()
+def spawn_sandbox(x):
+    modal.Sandbox.create("bash", "-c", "echo bar")