Combine with existing test methods module

Author: AlanCoding

test_work/__init__.py

@@ -31,5 +31,5 @@ def test_clear_math_by_worker_count(benchmark, workers, with_pool_server):
     root_dir = os.path.dirname(os.path.dirname(os.path.dirname(os.path.dirname(os.path.dirname(__file__)))))
     sys.path.append(root_dir)
 
-    with with_pool_server(workers, function='lambda: __import__("test_work.math").fibonacci(26)') as pool_server:
+    with with_pool_server(workers, function='lambda: __import__("tests.data.methods").fibonacci(26)') as pool_server:
         benchmark(pool_server.run_benchmark_test, pool_server.queue_in, pool_server.queue_out, 100)

test_work/math.py

@@ -26,3 +26,19 @@ def sleep_queue_one(seconds=1):
 @task(queue='test_channel')
 def print_hello():
     print('hello world!!')
+
+# fibonacci is a slow method in raw processing power
+# demo values - times n in seconds
+# 30 - 0.052
+# 29 - 0.035
+# 28 - 0.024
+# 27 - 0.015
+# 26 - 0.012
+# 25 - 0.0097
+
+@task(queue='test_channel')
+def fibonacci(n):
+    if n <= 1:
+        return n
+    else:
+        return fibonacci(n-1) + fibonacci(n-2)

tests/benchmark/pool/test_clear_time.py

@@ -17,11 +17,6 @@
 
 from test_methods import sleep_function, sleep_discard, task_has_timeout, hello_world_binder
 
-import os, sys
-
-sys.path.append(os.path.dirname(os.path.dirname(__file__)))
-
-from test_work.math import fibonacci
 
 # Database connection details
 CONNECTION_STRING = "dbname=dispatch_db user=dispatch password=dispatching host=localhost port=55777"
@@ -41,8 +36,6 @@ def main():
         publish_message(channel, message, config={'conninfo': CONNECTION_STRING})
         # await send_notification(channel, message)
 
-    fibonacci.apply_async(args=[29], config={'conninfo': CONNECTION_STRING})
-
     # send more than number of workers quickly
     print('')
     print('writing 15 messages fast')