Don't like ads? PRO users don't see any ads ;-)
Public Pastes
Guest

Hub, first run

By: krissaxton on Jul 31st, 2012  |  syntax: None  |  size: 2.65 KB  |  hits: 13  |  expires: Never
download  |  raw  |  embed  |  report abuse  |  print
Text below is selected. Please press Ctrl+C to copy to your clipboard. (⌘+C on Mac)
  1. Client:
  2. mba1:lib kris$ ./input.py
  3. Posting job '{"total": "_multiply.data", "tasks": [{"args": [1, 2], "name": "add"}, {"depends": ["add"], "args": ["_add.data", 2], "name": "multiply"}], "name": "addsum"}'
  4.  
  5. Dispatcher:
  6.  
  7. mba1:lib kris$ ./dispatcher.py
  8. Starting dispatcher, listening for jobs and results...
  9. Pending task add has no dependents, publishing...
  10. Task multiply waiting on results of [u'add']...
  11. Submitting task {'status': 'PENDING', 'parent_id': '65be707d-daf7-11e1-8867-109adda719a8', u'args': [1, 2], 'id': '65c20733-daf7-11e1-8c94-109adda719a8', u'name': u'add'} to work queue
  12. Sending task to worker.
  13. Received results '{"status": "SUCCESS", "name": "add", "args": [1, 2], "exit_code": 0, "parent_id": "65be707d-daf7-11e1-8867-109adda719a8", "msg": "Added two numbers", "data": 3, "id": "65c20733-daf7-11e1-8c94-109adda719a8"}'
  14. Found parent job record 65be707d-daf7-11e1-8867-109adda719a8 for task 65c20733-daf7-11e1-8c94-109adda719a8
  15. Updating task add with new results
  16. Found parametrised arg _add.data in task multiply
  17. Submitting task {'status': 'PENDING', u'name': u'multiply', u'args': [3, 2], 'parent_id': '65be707d-daf7-11e1-8867-109adda719a8', u'depends': [u'add'], 'id': '65c20a40-daf7-11e1-9af8-109adda719a8'} to work queue
  18. Sending task to worker.
  19. Received results '{"status": "SUCCESS", "name": "multiply", "args": [3, 2], "exit_code": 0, "parent_id": "65be707d-daf7-11e1-8867-109adda719a8", "depends": ["add"], "msg": "Multiplied two numbers", "data": 6, "id": "65c20a40-daf7-11e1-9af8-109adda719a8"}'
  20. Found parent job record 65be707d-daf7-11e1-8867-109adda719a8 for task 65c20a40-daf7-11e1-9af8-109adda719a8
  21. Updating task multiply with new results
  22. No more tasks to run for job 65be707d-daf7-11e1-8867-109adda719a8
  23.  
  24. Worker:
  25. mba1:lib kris$ ./worker.py
  26. Starting worker, waiting for jobs...
  27. Received '{"status": "PENDING", "parent_id": "65be707d-daf7-11e1-8867-109adda719a8", "args": [1, 2], "id": "65c20733-daf7-11e1-8c94-109adda719a8", "name": "add"}'
  28. Sending results to dispatcher.
  29. {'status': 'SUCCESS', u'name': u'add', u'args': [1, 2], 'exit_code': 0, u'parent_id': u'65be707d-daf7-11e1-8867-109adda719a8', 'msg': 'Added two numbers', 'data': 3, 'id': u'65c20733-daf7-11e1-8c94-109adda719a8'}
  30. Received '{"status": "PENDING", "name": "multiply", "args": [3, 2], "parent_id": "65be707d-daf7-11e1-8867-109adda719a8", "depends": ["add"], "id": "65c20a40-daf7-11e1-9af8-109adda719a8"}'
  31. Sending results to dispatcher.
  32. {'status': 'SUCCESS', u'name': u'multiply', u'args': [3, 2], 'exit_code': 0, u'parent_id': u'65be707d-daf7-11e1-8867-109adda719a8', u'depends': [u'add'], 'msg': 'Multiplied two numbers', 'data': 6, 'id': u'65c20a40-daf7-11e1-9af8-109adda719a8'}
create a new version of this paste RAW Paste Data