local proxy

doc/index.rst

@@ -7,3 +7,4 @@
     tasks
     workers
     collections
+    localproxy

doc/localproxy.rst

@@ -0,0 +1,27 @@
+Thread local proxy
+******************
+
+Simple proxy for *threading.local* namespace.
+
+.. code:: python
+
+    from atasker import g
+
+    if not g.has('db'):
+        g.set('db', <new_db_connection>)
+
+Supports methods:
+
+.. code:: python
+
+    # returns attr value or default value if specified
+    g.get(attr, default=None)
+
+    # returns True if attribute exists
+    g.has(attr)
+
+    # set attribute value
+    g.set(attr, value)
+
+    # delete attribute
+    g.clear(attr)

tests/test.py

@@ -30,11 +30,17 @@ def wait():
 
 from atasker import task_supervisor, background_task, background_worker, TT_MP
 
-from atasker import FunctionCollection, TaskCollection
+from atasker import FunctionCollection, TaskCollection, g
 
 
 class Test(unittest.TestCase):
 
+    def test_g(self):
+        g.set('test', 1)
+        g.clear('test')
+        g.set('test_is', g.has('test'))
+        self.assertFalse(g.get('test_is'))
+
     def test_function_collection(self):
 
         f = FunctionCollection()