From a019b70383917a91829ef98fc6dc27943ddb48ed 2015-01-30 21:57:37
From: Min RK <benjaminrk@gmail.com>
Date: 2015-01-30 21:57:37
Subject: [PATCH] remove dead workflow parallel example

---

diff --git a/examples/Parallel Computing/Index.ipynb b/examples/Parallel Computing/Index.ipynb
index f500583..d6e4fd8 100644
--- a/examples/Parallel Computing/Index.ipynb
+++ b/examples/Parallel Computing/Index.ipynb
@@ -321,24 +321,6 @@
      },
      "metadata": {},
      "output_type": "display_data"
-    },
-    {
-     "data": {
-      "text/html": [
-       "workflow/<br>\n",
-       "&nbsp;&nbsp;<a href='workflow/client.py' target='_blank'>client.py</a><br>\n",
-       "&nbsp;&nbsp;<a href='workflow/job_wrapper.py' target='_blank'>job_wrapper.py</a><br>\n",
-       "&nbsp;&nbsp;<a href='workflow/wmanager.py' target='_blank'>wmanager.py</a><br>"
-      ],
-      "text/plain": [
-       "workflow/\n",
-       "  client.py\n",
-       "  job_wrapper.py\n",
-       "  wmanager.py"
-      ]
-     },
-     "metadata": {},
-     "output_type": "display_data"
     }
    ],
    "source": [
diff --git a/examples/Parallel Computing/workflow/client.py b/examples/Parallel Computing/workflow/client.py
deleted file mode 100644
index 985e822..0000000
--- a/examples/Parallel Computing/workflow/client.py
+++ /dev/null
@@ -1,3 +0,0 @@
-from IPython.parallel.client import Client
-
-client = Client()
diff --git a/examples/Parallel Computing/workflow/job_wrapper.py b/examples/Parallel Computing/workflow/job_wrapper.py
deleted file mode 100755
index 216fe51..0000000
--- a/examples/Parallel Computing/workflow/job_wrapper.py
+++ /dev/null
@@ -1,25 +0,0 @@
-#!/usr/bin/env python
-"""Python wrapper around a submitted workflow job.
-
-In reality this would be a more sophisticated script, here we only illustrate
-the basic idea by considering that a submitted 'job' is a Python string to be
-executed.
-"""
-
-import sys
-
-argv = sys.argv
-
-from IPython.parallel.engine import EngineFactory
-from IPython.parallel.ipengineapp import launch_new_instance
-
-ns = {}
-
-# job
-exec sys.argv[1] in ns
-
-# this should really use Config:
-EngineFactory.user_ns = ns
-
-# start engine with job namespace
-launch_new_instance()
diff --git a/examples/Parallel Computing/workflow/wmanager.py b/examples/Parallel Computing/workflow/wmanager.py
deleted file mode 100644
index e4786b4..0000000
--- a/examples/Parallel Computing/workflow/wmanager.py
+++ /dev/null
@@ -1,44 +0,0 @@
-"""Mock workflow manager.
-
-This is a mock work manager whose submitted 'jobs' simply consist of executing
-a python string.  What we want is to see the implementation of the ipython
-controller part.
-"""
-
-from __future__ import print_function
-
-import atexit
-import sys
-
-from subprocess import Popen
-
-def cleanup(controller, engines):
-    """Cleanup routine to shut down all subprocesses we opened."""
-    import signal, time
-    
-    print('Starting cleanup')
-    print('Stopping engines...')
-    for e in engines:
-        e.send_signal(signal.SIGINT)
-    print('Stopping controller...')
-    # so it can shut down its queues
-    controller.send_signal(signal.SIGINT)
-    time.sleep(0.1)
-    print('Killing controller...')
-    controller.kill()
-    print('Cleanup done')
-
-
-if __name__ == '__main__':
-
-    # Start controller in separate process
-    cont = Popen(['python', '-m', 'IPython.parallel.ipcontrollerapp'])
-    print('Started controller')
-
-    # "Submit jobs"
-    eng = []
-    for i in range(4):
-        eng.append(Popen(['python', 'job_wrapper.py','x=%s' % i]))
-
-    # Ensure that all subpro
-    atexit.register(lambda : cleanup(cont, eng))
diff --git a/tools/run_ipy_in_profiler.py b/tools/run_ipy_in_profiler.py
deleted file mode 100755
index 7362293..0000000
--- a/tools/run_ipy_in_profiler.py
+++ /dev/null
@@ -1,23 +0,0 @@
-#!/usr/bin/env python
-"""XXX - What exactly is the use of this script?
-
-I (fperez) tried it quickly and it doesn't work in its current form.  Either it
-needs to be fixed and documented or removed.
-"""
-
-import cProfile as profile
-import sys
-#import profile
-
-def main():
-    import IPython.ipapi
-    print "Entering ipython for profiling. Type 'Exit' for profiler report"
-    IPython.ipapi.launch_new_instance()
-
-if len(sys.argv) == 1:
-    profile.run('main()', 'ipython_profiler_results')
-
-import pstats
-p = pstats.Stats(len(sys.argv) >1 and sys.argv[1] or 'ipython_profiler_results')
-p.sort_stats('time').print_stats(30)
-