79 lines
2.6 KiB
Python
79 lines
2.6 KiB
Python
#!/usr/bin/env python3
|
|
# This is free software for the public good of a permacomputer hosted at
|
|
# permacomputer.com, an always-on computer by the people, for the people.
|
|
# One which is durable, easy to repair, & distributed like tap water
|
|
# for machine learning intelligence.
|
|
#
|
|
# The permacomputer is community-owned infrastructure optimized around
|
|
# four values:
|
|
#
|
|
# TRUTH First principles, math & science, open source code freely distributed
|
|
# FREEDOM Voluntary partnerships, freedom from tyranny & corporate control
|
|
# HARMONY Minimal waste, self-renewing systems with diverse thriving connections
|
|
# LOVE Be yourself without hurting others, cooperation through natural law
|
|
#
|
|
# This software contributes to that vision by enabling code execution across 42+ programming languages through a unified interface, accessible to all.
|
|
# Code is seeds to sprout on any abandoned technology.
|
|
|
|
"""
|
|
Async job polling example - demonstrates fire-and-forget execution
|
|
|
|
This example shows how to:
|
|
1. Start jobs asynchronously with execute_async()
|
|
2. Poll job status with get_job()
|
|
3. Wait for completion with wait_for_job()
|
|
4. Cancel jobs with cancel_job()
|
|
|
|
Usage:
|
|
python async_job_polling.py
|
|
|
|
Or with custom credentials:
|
|
UNSANDBOX_PUBLIC_KEY=... UNSANDBOX_SECRET_KEY=... python async_job_polling.py
|
|
"""
|
|
|
|
import asyncio
|
|
import sys
|
|
import os
|
|
|
|
# Add src to path for development
|
|
sys.path.insert(0, os.path.join(os.path.dirname(__file__), "..", "src"))
|
|
|
|
try:
|
|
from un_async import execute_async, get_job, wait_for_job, list_jobs
|
|
except ImportError as e:
|
|
print(f"Missing dependency: {e}")
|
|
print("Install with: pip install aiohttp")
|
|
sys.exit(0) # Exit gracefully for CI
|
|
|
|
|
|
async def main():
|
|
"""Demonstrate async job operations."""
|
|
try:
|
|
print("1. Starting async job...")
|
|
job_id = await execute_async("python", 'print("Job result")')
|
|
print(f" Job ID: {job_id}")
|
|
|
|
print("\n2. Checking job status...")
|
|
job_status = await get_job(job_id)
|
|
print(f" Status: {job_status.get('status')}")
|
|
|
|
print("\n3. Waiting for job completion...")
|
|
result = await wait_for_job(job_id)
|
|
print(f" Final status: {result.get('status')}")
|
|
print(f" Output: {result.get('stdout', '').strip()}")
|
|
|
|
print("\n4. Listing all jobs...")
|
|
jobs = await list_jobs()
|
|
print(f" Total jobs: {len(jobs)}")
|
|
if jobs:
|
|
print(f" Most recent job ID: {jobs[0].get('id')}")
|
|
|
|
return 0
|
|
except Exception as e:
|
|
print(f"Error: {e}", file=sys.stderr)
|
|
return 1
|
|
|
|
|
|
if __name__ == "__main__":
|
|
exit_code = asyncio.run(main())
|
|
sys.exit(exit_code)
|