From 5a43df542deec6447187ed58b3709e411af96546 Mon Sep 17 00:00:00 2001 From: Chris Patton Date: Wed, 29 Jul 2020 11:21:11 -0700 Subject: [PATCH] simplify examples --- examples/examples.py | 18 ++++++++---------- 1 file changed, 8 insertions(+), 10 deletions(-) diff --git a/examples/examples.py b/examples/examples.py index c47cecf..38433e4 100644 --- a/examples/examples.py +++ b/examples/examples.py @@ -2,15 +2,13 @@ from redis import Redis from rq_manager import manager, getProjectResults -from exampleTasks import addSubJob, simpleTask, addJobs, addSubJob -from pprint import pprint +from exampleTasks import addSubJob, simpleTask, addJobs, addSubJob #### Examples are slow because "sleepTime" default is 1 second #### # Tell RQ what Redis connection to use -redis_conn = Redis() -q = Queue(connection=redis_conn,is_async=True) # no args implies the default queue +q = Queue(connection=Redis()) ### Run jobs in parallel: project = {'jobs':[ @@ -20,7 +18,7 @@ managerJob = q.enqueue(manager,project) projectResults = getProjectResults(managerJob) -pprint(projectResults) +print(projectResults) ### Run jobs in series: project = {'jobs':[ @@ -30,7 +28,7 @@ managerJob = q.enqueue(manager,project) projectResults = getProjectResults(managerJob) -pprint(projectResults) +print(projectResults) ### Run with dependent arguments: project = {'jobs':[ @@ -41,7 +39,7 @@ managerJob = q.enqueue(manager,project) projectResults = getProjectResults(managerJob) -pprint(projectResults) +print(projectResults) ### Run jobs with multiple dependancy: project = {'jobs':[ @@ -58,7 +56,7 @@ managerJob = q.enqueue(manager,project) projectResults = getProjectResults(managerJob) -pprint(projectResults) +print(projectResults) ### Add jobs as you go project = {'jobs':[ @@ -75,7 +73,7 @@ managerJob = q.enqueue(manager,project) projectResults = getProjectResults(managerJob) -pprint(projectResults) +print(projectResults) ### Add a job with child jobs as you go project = {'jobs':[ @@ -92,4 +90,4 @@ managerJob = q.enqueue(manager,project) projectResults = getProjectResults(managerJob) -pprint(projectResults) \ No newline at end of file +print(projectResults) \ No newline at end of file