job_subprocess.py

# subprocess job template for easyrpc_job_runner
import asyncio, sys, json
from easyrpc.proxy import EasyRpcProxy

async def job(reuest_id, payload):
    proxy = await EasyRpcProxy.create(
        '0.0.0.0', 
        8690, 
        '/ws/jobs', 
        server_secret='abcd1234',
        namespace='jobs'
    )

    # insert work here
    results = 'subprocess results' # dont use this
    await proxy['send_results'](request_id, results)
if __name__ == '__main__':
    payload = json.load(sys.stdin)
    request_id = sys.argv[1]
    asyncio.run(job(request_id, payload))