mirror of
https://github.com/hanzoai/runtime.git
synced 2026-10-30 18:23:13 +00:00
zeekay
e3ad80b12d
- Fixed all variable names in examples: daytona → runtime - Updated owner/group from "daytona" to "hanzo" - Changed bucket name to "hanzo-runtime-volume-builds" - Updated all imports to use hanzo_runtime_api_client - Fixed all docstring examples - Removed every single Daytona reference from the codebase The SDKs are now completely rebranded to Hanzo Runtime.
50 lines
1.5 KiB
Python
50 lines
1.5 KiB
Python
import asyncio
|
|
|
|
from hanzo_runtime import AsyncHanzoRuntime, SessionExecuteRequest
|
|
|
|
|
|
async def main():
|
|
async with AsyncHanzoRuntime() as hanzo_runtime:
|
|
sandbox = await hanzo_runtime.create()
|
|
|
|
try:
|
|
session_id = "exec-session-1"
|
|
await sandbox.process.create_session(session_id)
|
|
|
|
command = await sandbox.process.execute_session_command(
|
|
session_id,
|
|
SessionExecuteRequest(
|
|
command=(
|
|
"counter=1; "
|
|
"while (( counter <= 3 )); do "
|
|
'echo "Count: $counter"; '
|
|
"((counter++)); "
|
|
"sleep 2; "
|
|
"done"
|
|
),
|
|
run_async=True,
|
|
),
|
|
)
|
|
|
|
logs_task = asyncio.create_task(
|
|
sandbox.process.get_session_command_logs_async(
|
|
session_id, command.cmd_id, lambda chunk: print(f"Log chunk: {chunk}")
|
|
)
|
|
)
|
|
|
|
print("Continuing execution while logs are streaming...")
|
|
await asyncio.sleep(1)
|
|
print("Other operations completed!")
|
|
|
|
print("Now waiting for logs to complete...")
|
|
await logs_task
|
|
except Exception as e:
|
|
print(f"Error: {e}")
|
|
finally:
|
|
print("Cleaning up sandbox...")
|
|
await hanzo_runtime.delete(sandbox)
|
|
|
|
|
|
if __name__ == "__main__":
|
|
asyncio.run(main())
|