diff --git a/modal/experimental.py b/modal/experimental.py index 9a45edbd7..34b864cf9 100644 --- a/modal/experimental.py +++ b/modal/experimental.py @@ -14,17 +14,18 @@ def stop_fetching_inputs(): _ContainerIOManager.stop_fetching_inputs() + + def get_local_input_concurrency(): """Get the container's local input concurrency. Return 0 if the container is not running.""" return _ContainerIOManager.get_input_concurrency() async def _logger(message: str) -> None: - """Log a message to the Modal logs.""" + """Send a structured log with tags.""" request = api_pb2.ContainerLogRequest(message=message, input_id=current_input_id()) io_manager = _ContainerIOManager._singleton assert io_manager is not None await retry_transient_errors(io_manager._client.stub.ContainerLog, request) - logger = synchronize_api(_logger)