Adapt examples so they run again.

Remove sync part of the example.

examples/run_example.py

@@ -1,37 +1,31 @@
 import os
 import time
-from rq import push_connection
+from rq import conn
 from redis import Redis
 from fib import slow_fib
 
-push_connection(Redis())
+# Tell rq what Redis connection to use
+conn.push(Redis())
 
-sync = False
+# Kick off the tasks asynchronously
-if sync:
+async_results = {}
-    print 'Synchronously:'
+for x in range(20, 30):
-    for x in range(22, 33):
+    async_results[x] = slow_fib.delay(x)
-        print 'fib(%d) = %d' % (x, slow_fib(x))
-    print 'Done'
-else:
-    # Kick off the tasks asynchronously
-    async_results = {}
-    for x in range(22, 33):
-        async_results[x] = slow_fib.delay(x)
 
-    done = False
+done = False
-    while not done:
+while not done:
-        os.system('clear')
+    os.system('clear')
-        print 'Asynchronously: (now = %s)' % time.time()
+    print 'Asynchronously: (now = %s)' % time.time()
-        done = True
+    done = True
-        for x in range(22, 33):
+    for x in range(20, 30):
-            result = async_results[x].return_value
+        result = async_results[x].return_value
-            if result is None:
+        if result is None:
-                done = False
+            done = False
-                result = '(calculating)'
+            result = '(calculating)'
-            print 'fib(%d) = %s' % (x, result)
+        print 'fib(%d) = %s' % (x, result)
-        print ''
+    print ''
-        print 'To start the actual in the background, run a worker:'
+    print 'To start the actual in the background, run a worker:'
-        print '    python examples/run_worker.py'
+    print '    python examples/run_worker.py'
-        time.sleep(1)
+    time.sleep(1)
 
-    print 'Done'
+print 'Done'

examples/run_worker.py

@@ -1,7 +1,9 @@
 from redis import Redis
-from rq import push_connection
+from rq import conn
 from rq.daemon import run_daemon
 
-push_connection(Redis())
+# Tell rq what Redis connection to use
+conn.push(Redis())
 
-run_daemon(['default'])
+listen_on_queues = ['default']
+run_daemon(listen_on_queues)