feat: update Dockerfile to use Python 3.12 and improve bashrc for virtual environment activation; enhance execute_command example with error handling and log streaming

Author: akosyakov

.devcontainer/Dockerfile

@@ -1,9 +1,8 @@
-ARG VARIANT="3.9"
-FROM mcr.microsoft.com/vscode/devcontainers/python:0-${VARIANT}
+FROM mcr.microsoft.com/devcontainers/python:3.12
 
 USER vscode
 
 RUN curl -sSf https://rye.astral.sh/get | RYE_VERSION="0.35.0" RYE_INSTALL_OPTION="--yes" bash
 ENV PATH=/home/vscode/.rye/shims:$PATH
 
-RUN echo "[[ -d .venv ]] && source .venv/bin/activate" >> /home/vscode/.bashrc
+RUN echo "[[ -d .venv ]] && source .venv/bin/activate || export PATH=\$PATH" >> /home/vscode/.bashrc

examples/execute_command.py

@@ -28,7 +28,7 @@ def main() -> None:
         reference = "hello-world"
         task = client.environments.automations.tasks.create(
             spec={
-                "command": "echo 'Hello, World!'"
+                "command": "echo 'Hello, World!' && false",
             },
             environment_id=environment_id,
             metadata={
@@ -54,7 +54,6 @@ def main() -> None:
 
         log_url = None
         for event in event_stream:
-            print(f"Received event: {event}")
             if event.resource_type == "RESOURCE_TYPE_ENVIRONMENT" and event.resource_id == environment_id:
                 check_environment_status(client, environment_id)
             elif event.resource_type == "RESOURCE_TYPE_TASK_EXECUTION" and event.resource_id == execution.id:
@@ -63,15 +62,23 @@ def main() -> None:
                 if execution.status.log_url:
                     log_url = execution.status.log_url
                     break
+
+        event_stream.http_response.close()
 
         if not log_url:
             raise RuntimeError("Task logs are not available.")
 
         print(f"Task logs are available at: {log_url}")
+        print("")
+        print("Streaming logs:")
 
-        # Stream the log URL and print the logs
         asyncio.run(stream_logs(log_url, logs_access_token))
 
+        execution = client.environments.automations.tasks.executions.retrieve(id=execution.id).task_execution
+        print(f"Task execution status: {execution.status.phase}")
+        if execution.status.phase == "TASK_EXECUTION_PHASE_FAILED":
+            print(f"Task execution failed: {execution.status.failure_message}")
+
     finally:
         client.environments.delete(environment_id=environment_id)
         print(f"Deleted environment: {environment_id}")