Version 0.9.2 (#48)

Adding option of kwargs to task for tasker
Fixing documentations links

Author: cdgriffith

CHANGES.rst

@@ -1,6 +1,12 @@
 Changelog
 =========
 
+Version 0.9.2
+-------------
+
+- Adding option of kwargs to task for tasker
+- Fixing documentations links
+
 Version 0.9.1
 -------------
 

README.rst

@@ -441,8 +441,8 @@ improve existing code is warmly welcomed!
 .. toctree::
    :maxdepth: 2
 
-   reusables
-   browser
+   file_operations
+   tasker
    log
    datetime
    namespace

doc/source/browser.rst

@@ -0,0 +1,6 @@
+File Operations
+===============
+
+.. automodule:: reusables.file_operations
+   :members:
+   :undoc-members:

doc/source/file_operations.rst

@@ -1,6 +1,6 @@
 Multiprocess Helpers
 ====================
 
-.. automodule:: reusables.multiprocess_helpers
+.. automodule:: reusables.process_helpers
    :members:
    :undoc-members:

doc/source/multiprocess_helpers.rst

@@ -1,6 +1,6 @@
 Numbers
 =======
 
-.. automodule:: reusables.numbers
+.. automodule:: reusables.string_manipulation
    :members:
    :undoc-members:

doc/source/numbers.rst

@@ -0,0 +1,8 @@
+Tasker
+======
+
+.. automodule:: reusables.tasker
+   :members:
+   :undoc-members:
+
+

doc/source/reusables.rst

@@ -20,4 +20,4 @@
 from reusables.wrappers import *
 
 __author__ = "Chris Griffith"
-__version__ = "0.9.1"
+__version__ = "0.9.2"

doc/source/tasker.rst

@@ -47,7 +47,7 @@ class Tasker(object):
 
     def __init__(self, tasks=(), max_tasks=4, task_timeout=None,
                  task_queue=None, result_queue=None, command_queue=None,
-                 run_until=None, logger='reusables'):
+                 run_until=None, logger='reusables', **task_kwargs):
         if logger:
             self.log = logging.getLogger('reusables')
         self.task_queue = task_queue or mp.Queue()
@@ -66,6 +66,7 @@ def __init__(self, tasks=(), max_tasks=4, task_timeout=None,
         self.run_until = run_until
         self._pause, self._end = mp.Value('b', False), mp.Value('b', False)
         self.background_process = None
+        self.task_kwargs = task_kwargs
 
     def get(self, timeout=None):
         """Retrieve next result from the queue"""
@@ -76,7 +77,7 @@ def put(self, task):
         return self.task_queue.put(task)
 
     @staticmethod
-    def perform_task(task, result_queue):
+    def perform_task(task, result_queue, **kwargs):
         """Function to be overwritten that performs the tasks from the list"""
         raise NotImplementedError()
 
@@ -113,7 +114,8 @@ def _return_task(self, task_id):
 
     def _start_task(self, task_id, task):
         self.current_tasks[task_id]['proc'] = mp.Process(
-            target=self.perform_task, args=(task, self.result_queue))
+            target=self.perform_task, args=(task, self.result_queue),
+            kwargs=self.task_kwargs)
         self.current_tasks[task_id]['start_time'] = time.time()
         self.current_tasks[task_id]['proc'].start()