goosemo

$ git push origin master
fatal: remote error:
  GitHub is offline for maintenance. See http://status.github.com for more info.

goosemo

$ make install 
\n\nSilently installing packages (this will take a while)...
PIP_FIND_LINKS='http://mypipi http://simple.crate.io/' bin/pip install -r requirements.txt
Downloading/unpacking http://uploads.mitechie.com/dist/convoy-0.2.0.tar.gz (from -r requirements.txt (line 5))
  Downloading convoy-0.2.0.tar.gz
  Running setup.py egg_info for package from http://uploads.mitechie.com/dist/convoy-0.2.0.tar.gz
    
Requirement already satisfied (use --upgrade to upgrade): argparse in ./lib/python2.7/site-packages (from -r requirements.txt (line 1))
Requirement already satisfied (use --upgrade to upgrade): BeautifulSoup==3.2.0 in ./lib/python2.7/site-packages (from -r requirements.txt (line 2))
Requirement already satisfied (use --upgrade to upgrade): Chameleon==1.3.0-rc1 in ./lib/python2.7/site-packages (from -r requirements.txt (line 3))

goosemo

$ python gist0926a9caba7d26c0fabb-f11495d2f6de4bb168afe28a8eba1028230cb84f/gistfile1.py
Synchronous:
With Gevent:
Took 6.38158893585 seconds...
With Multiprocessing:

╭─mgoose@mgoose-ml  ~ 
╰─$ vim gist0926a9caba7d26c0fabb-f11495d2f6de4bb168afe28a8eba1028230cb84f/gistfile1.py

╭─mgoose@mgoose-ml  ~ 

goosemo

#CPU Bound
#serialrun took 1389.423 ms
#geventrun took 1511.781 ms
#parallelrun took 343.161 ms
#threadedrun took 2853.815 ms
#
#
#IO Bound
#serialrun took 1908.858 ms
#geventrun took 24857.715 ms

goosemo

#!/usr/bin/env python

#from gevent import monkey
#monkey.patch_all()
#import gevent

import multiprocessing

import json
import random

goosemo

from fabric.api import *

@parallel
@hosts("hosta", "hostb")
def test1():
    local("exit 0")
    if env.host == "hostb":
        local("exit 1")
    
@parallel

goosemo

╭─mgoose@mgoose-ml  ~/workspace/fabric ‹457-failure-checking-for-parallel*› 
╰─$ fab                                                                                                                                                  (env: fabric-testing) 1 ↵
Failure: ImportError (cannot import name tasks) ... ERROR
Failure: ImportError (cannot import name state) ... ERROR
Doctest: fabric.operations._shell_escape ... ok
Doctest: fabric.state._AttributeDict ... ok
cd cleans up after itself even in case of an exception ... FAIL
cd() should append arg if non-absolute or overwrite otherwise ... FAIL
Using settings() with a previously nonexistent key should work correctly ... FAIL
settings() should temporarily override env dict with given key/value pair ... FAIL

goosemo

╭─mgoose@mgoose-ml  ~/workspace/fabric/fabric ‹457-failure-checking-for-parallel*› 
╰─$ git diff
diff --git a/fabric/job_queue.py b/fabric/job_queue.py
index e0fd0ce..b64f390 100644
--- a/fabric/job_queue.py
+++ b/fabric/job_queue.py
@@ -10,6 +10,7 @@ from Crypto import Random
 import time
 
 from fabric.state import env, io_sleep