Restoring authorship annotation for Aleksandr <ivansduck@gmail.com>. Commit 2 of 2.

1 files changed, 97 insertions, 97 deletions

diff --git a/library/python/func/__init__.py b/library/python/func/__init__.py
index e37ea95c7c..7424361635 100644
--- a/library/python/func/__init__.py
+++ b/library/python/func/__init__.py
@@ -1,6 +1,6 @@
 import functools
-import threading 
-import collections 
+import threading
+import collections
 
 
 def map0(func, value):
@@ -20,12 +20,12 @@ class _Result(object):
 def lazy(func):
     result = _Result()
 
-    @functools.wraps(func) 
-    def wrapper(*args): 
+    @functools.wraps(func)
+    def wrapper(*args):
         try:
             return result.result
         except AttributeError:
-            result.result = func(*args) 
+            result.result = func(*args)
 
         return result.result
 
@@ -64,54 +64,54 @@ class lazy_classproperty(object):
         return getattr(owner, attr_name)
 
 
-def memoize(limit=0, thread_local=False): 
-    assert limit >= 0 
- 
+def memoize(limit=0, thread_local=False):
+    assert limit >= 0
+
     def decorator(func):
-        memory = {} 
-        lock = threading.Lock() 
- 
-        if limit: 
-            keys = collections.deque() 
- 
-            def get(args): 
-                try: 
-                    return memory[args] 
-                except KeyError: 
-                    with lock: 
-                        if args not in memory: 
-                            fargs = args[-1] 
-                            memory[args] = func(*fargs) 
-                            keys.append(args) 
-                            if len(keys) > limit: 
-                                del memory[keys.popleft()] 
-                        return memory[args] 
-
-        else: 
- 
-            def get(args): 
-                if args not in memory: 
-                    with lock: 
-                        if args not in memory: 
-                            fargs = args[-1] 
-                            memory[args] = func(*fargs) 
-                return memory[args] 
- 
-        if thread_local: 
- 
-            @functools.wraps(func) 
-            def wrapper(*args): 
-                th = threading.current_thread() 
-                return get((th.ident, th.name, args)) 
- 
-        else: 
- 
-            @functools.wraps(func) 
-            def wrapper(*args): 
-                return get(('', '', args)) 
- 
-        return wrapper 
- 
+        memory = {}
+        lock = threading.Lock()
+
+        if limit:
+            keys = collections.deque()
+
+            def get(args):
+                try:
+                    return memory[args]
+                except KeyError:
+                    with lock:
+                        if args not in memory:
+                            fargs = args[-1]
+                            memory[args] = func(*fargs)
+                            keys.append(args)
+                            if len(keys) > limit:
+                                del memory[keys.popleft()]
+                        return memory[args]
+
+        else:
+
+            def get(args):
+                if args not in memory:
+                    with lock:
+                        if args not in memory:
+                            fargs = args[-1]
+                            memory[args] = func(*fargs)
+                return memory[args]
+
+        if thread_local:
+
+            @functools.wraps(func)
+            def wrapper(*args):
+                th = threading.current_thread()
+                return get((th.ident, th.name, args))
+
+        else:
+
+            @functools.wraps(func)
+            def wrapper(*args):
+                return get(('', '', args))
+
+        return wrapper
+
     return decorator
 
 
@@ -119,52 +119,52 @@ def memoize(limit=0, thread_local=False):
 def compose(*functions):
     def compose2(f, g):
         return lambda x: f(g(x))
- 
+
     return functools.reduce(compose2, functions, lambda x: x)
- 
- 
-class Singleton(type): 
-    _instances = {} 
- 
-    def __call__(cls, *args, **kwargs): 
-        if cls not in cls._instances: 
-            cls._instances[cls] = super(Singleton, cls).__call__(*args, **kwargs) 
-        return cls._instances[cls] 
- 
- 
-def stable_uniq(it): 
-    seen = set() 
-    res = [] 
-    for e in it: 
-        if e not in seen: 
-            res.append(e) 
-            seen.add(e) 
-    return res 
- 
- 
-def first(it): 
-    for d in it: 
-        if d: 
-            return d 
- 
- 
-def split(data, func): 
-    l, r = [], [] 
-    for e in data: 
-        if func(e): 
-            l.append(e) 
-        else: 
-            r.append(e) 
-    return l, r 
+
+
+class Singleton(type):
+    _instances = {}
+
+    def __call__(cls, *args, **kwargs):
+        if cls not in cls._instances:
+            cls._instances[cls] = super(Singleton, cls).__call__(*args, **kwargs)
+        return cls._instances[cls]
+
+
+def stable_uniq(it):
+    seen = set()
+    res = []
+    for e in it:
+        if e not in seen:
+            res.append(e)
+            seen.add(e)
+    return res
+
+
+def first(it):
+    for d in it:
+        if d:
+            return d
+
+
+def split(data, func):
+    l, r = [], []
+    for e in data:
+        if func(e):
+            l.append(e)
+        else:
+            r.append(e)
+    return l, r
 
 
 def flatten_dict(dd, separator='.', prefix=''):
-    return ( 
-        { 
-            prefix + separator + k if prefix else k: v 
-            for kk, vv in dd.items() 
-            for k, v in flatten_dict(vv, separator, kk).items() 
-        } 
-        if isinstance(dd, dict) 
-        else {prefix: dd} 
-    ) 
+    return (
+        {
+            prefix + separator + k if prefix else k: v
+            for kk, vv in dd.items()
+            for k, v in flatten_dict(vv, separator, kk).items()
+        }
+        if isinstance(dd, dict)
+        else {prefix: dd}
+    )