python-workq
Python Client for Workq with asyncio .
Requirements
- Python3.5+
Usage
Enqueue Foreground Job
import asyncio
import uuid
from workq.workq import WorkqClient
from workq.job import ForegroundJob
def main():
loop = asyncio.new_event_loop()
client = WorkqClient('127.0.0.1', 9922, loop)
jobid = uuid.uuid4()
job = ForegroundJob(jobid, "ping1", 5000, 60000, "hello fg job")
try:
loop.run_until_complete(client.connect())
results = loop.run_until_complete(client.run(job))
finally:
loop.close()
for result in results:
print("job: %s %s %s" % (result.id, result.name, result.payload))
if __name__ == '__main__':
main()
TODO
- [ ] inspect command