blacked the code

Author: wolph

_python_utils_tests/test_decorators.py

@@ -8,13 +8,15 @@
 @pytest.fixture
 def random(monkeypatch):
     mock = MagicMock()
-    monkeypatch.setattr("python_utils.decorators.random.random", mock, raising=True)
+    monkeypatch.setattr(
+        "python_utils.decorators.random.random", mock, raising=True
+    )
     return mock
 
 
 def test_sample_called(random):
     demo_function = MagicMock()
-    decorated = sample(0.5)(demo_function)    
+    decorated = sample(0.5)(demo_function)
     random.return_value = 0.4
     decorated()
     random.return_value = 0.0
@@ -33,4 +35,4 @@ def test_sample_not_called(random):
     decorated()
     random.return_value = 1.0
     decorated()
-    assert demo_function.call_count == 0
+    assert demo_function.call_count == 0

_python_utils_tests/test_generators.py

@@ -16,8 +16,7 @@ async def test_abatcher():
 async def test_abatcher_timed():
     batches = []
     async for batch in python_utils.abatcher(
-        python_utils.acount(stop=10, delay=0.08),
-        interval=0.2
+        python_utils.acount(stop=10, delay=0.08), interval=0.2
     ):
         batches.append(batch)
 

_python_utils_tests/test_import.py

@@ -17,16 +17,20 @@ def test_import_globals_without_inspection():
     locals_ = {}
     globals_ = {'__name__': __name__}
     import_.import_global(
-        'python_utils.formatters', locals_=locals_, globals_=globals_)
+        'python_utils.formatters', locals_=locals_, globals_=globals_
+    )
     assert 'camel_to_underscore' in globals_
 
 
 def test_import_globals_single_method():
     locals_ = {}
     globals_ = {'__name__': __name__}
     import_.import_global(
-        'python_utils.formatters', ['camel_to_underscore'], locals_=locals_,
-        globals_=globals_)
+        'python_utils.formatters',
+        ['camel_to_underscore'],
+        locals_=locals_,
+        globals_=globals_,
+    )
     assert 'camel_to_underscore' in globals_
 
 
@@ -37,12 +41,13 @@ def test_import_globals_with_inspection():
 
 def test_import_globals_missing_module():
     import_.import_global(
-        'python_utils.spam', exceptions=ImportError, locals_=locals())
+        'python_utils.spam', exceptions=ImportError, locals_=locals()
+    )
     assert 'camel_to_underscore' in globals()
 
 
 def test_import_locals_missing_module():
     import_.import_global(
-        'python_utils.spam', exceptions=ImportError, globals_=globals())
+        'python_utils.spam', exceptions=ImportError, globals_=globals()
+    )
     assert 'camel_to_underscore' in globals()
-

_python_utils_tests/test_python_utils.py

@@ -7,4 +7,3 @@ def test_definitions():
     assert __about__.__author__
     assert __about__.__author_email__
     assert __about__.__description__
-

_python_utils_tests/test_time.py

@@ -8,39 +8,54 @@
 
 
 @pytest.mark.parametrize(
-    'timeout,interval,interval_multiplier,maximum_interval,iterable,result', [
+    'timeout,interval,interval_multiplier,maximum_interval,iterable,result',
+    [
         (0.2, 0.1, 0.4, 0.2, python_utils.acount, 2),
         (0.3, 0.1, 0.4, 0.2, python_utils.acount(), 3),
         (0.3, 0.06, 1.0, None, python_utils.acount, 5),
-        (timedelta(seconds=0.1), timedelta(seconds=0.06),
-         2.0, timedelta(seconds=0.1), python_utils.acount, 2),
-    ])
+        (
+            timedelta(seconds=0.1),
+            timedelta(seconds=0.06),
+            2.0,
+            timedelta(seconds=0.1),
+            python_utils.acount,
+            2,
+        ),
+    ],
+)
 @pytest.mark.asyncio
-async def test_aio_timeout_generator(timeout, interval, interval_multiplier,
-                                     maximum_interval, iterable, result):
+async def test_aio_timeout_generator(
+    timeout, interval, interval_multiplier, maximum_interval, iterable, result
+):
     i = None
     async for i in python_utils.aio_timeout_generator(
-        timeout, interval, iterable,
-        maximum_interval=maximum_interval
+        timeout, interval, iterable, maximum_interval=maximum_interval
     ):
         pass
 
     assert i == result
 
 
 @pytest.mark.parametrize(
-    'timeout,interval,interval_multiplier,maximum_interval,iterable,result', [
+    'timeout,interval,interval_multiplier,maximum_interval,iterable,result',
+    [
         (0.01, 0.006, 0.5, 0.01, 'abc', 'c'),
         (0.01, 0.006, 0.5, 0.01, itertools.count, 2),
         (0.01, 0.006, 0.5, 0.01, itertools.count(), 2),
         (0.01, 0.006, 1.0, None, 'abc', 'c'),
-        (timedelta(seconds=0.01),
-         timedelta(seconds=0.006),
-         2.0, timedelta(seconds=0.01),
-         itertools.count, 2),
-    ])
-def test_timeout_generator(timeout, interval, interval_multiplier,
-                           maximum_interval, iterable, result):
+        (
+            timedelta(seconds=0.01),
+            timedelta(seconds=0.006),
+            2.0,
+            timedelta(seconds=0.01),
+            itertools.count,
+            2,
+        ),
+    ],
+)
+def test_timeout_generator(
+    timeout, interval, interval_multiplier, maximum_interval, iterable, result
+):
     i = None
     for i in python_utils.timeout_generator(
         timeout=timeout,
@@ -104,8 +119,7 @@ async def generator():
 
     # Test regular timeout with clean exit
     @python_utils.aio_generator_timeout_detector_decorator(
-        timeout=0.05,
-        on_timeout=None
+        timeout=0.05, on_timeout=None
     )
     async def generator():
         for i in range(10):
@@ -130,8 +144,7 @@ async def generator():
 
     # Test total timeout with clean exit
     @python_utils.aio_generator_timeout_detector_decorator(
-        total_timeout=0.1,
-        on_timeout=None
+        total_timeout=0.1, on_timeout=None
     )
     async def generator():
         for i in range(10):

python_utils/__about__.py

@@ -3,7 +3,8 @@
 __author_email__: str = 'Wolph@wol.ph'
 __description__: str = (
     'Python Utils is a module with some convenient utilities not included '
-    'with the standard Python install')
+    'with the standard Python install'
+)
 __url__: str = 'https://github.com/WoLpH/python-utils'
 # Omit type info due to automatic versioning script
 __version__ = '3.3.1'

python_utils/containers.py

@@ -28,21 +28,17 @@ class CastedDictBase(types.Dict[KT, VT], abc.ABC):
     _value_cast: VT_cast
 
     def __init__(
-            self,
-            key_cast: KT_cast = None,
-            value_cast: VT_cast = None,
-            *args,
-            **kwargs
+        self,
+        key_cast: KT_cast = None,
+        value_cast: VT_cast = None,
+        *args,
+        **kwargs,
     ) -> None:
         self._value_cast = value_cast
         self._key_cast = key_cast
         self.update(*args, **kwargs)
 
-    def update(
-            self,
-            *args: DictUpdateArgs,
-            **kwargs: VT
-    ) -> None:
+    def update(self, *args: DictUpdateArgs, **kwargs: VT) -> None:
         if args:
             kwargs.update(*args)
 

python_utils/converters.py

@@ -7,10 +7,10 @@
 
 
 def to_int(
-        input_: typing.Optional[str] = None,
-        default: int = 0,
-        exception: types.ExceptionsType = (ValueError, TypeError),
-        regexp: types.O[types.Pattern] = None,
+    input_: typing.Optional[str] = None,
+    default: int = 0,
+    exception: types.ExceptionsType = (ValueError, TypeError),
+    regexp: types.O[types.Pattern] = None,
 ) -> int:
     r'''
     Convert the given input to an integer or return default
@@ -97,10 +97,10 @@ def to_int(
 
 
 def to_float(
-        input_: str,
-        default: int = 0,
-        exception: types.ExceptionsType = (ValueError, TypeError),
-        regexp: types.O[types.Pattern] = None,
+    input_: str,
+    default: int = 0,
+    exception: types.ExceptionsType = (ValueError, TypeError),
+    regexp: types.O[types.Pattern] = None,
 ) -> types.Number:
     r'''
     Convert the given `input_` to an integer or return default
@@ -174,9 +174,9 @@ def to_float(
 
 
 def to_unicode(
-        input_: types.StringTypes,
-        encoding: str = 'utf-8',
-        errors: str = 'replace',
+    input_: types.StringTypes,
+    encoding: str = 'utf-8',
+    errors: str = 'replace',
 ) -> str:
     '''Convert objects to unicode, if needed decodes string with the given
     encoding and errors settings.
@@ -203,9 +203,9 @@ def to_unicode(
 
 
 def to_str(
-        input_: types.StringTypes,
-        encoding: str = 'utf-8',
-        errors: str = 'replace',
+    input_: types.StringTypes,
+    encoding: str = 'utf-8',
+    errors: str = 'replace',
 ) -> bytes:
     '''Convert objects to string, encodes to the given encoding
 
@@ -234,7 +234,8 @@ def to_str(
 
 
 def scale_1024(
-        x: types.Number, n_prefixes: int,
+    x: types.Number,
+    n_prefixes: int,
 ) -> types.Tuple[types.Number, types.Number]:
     '''Scale a number down to a suitable size, based on powers of 1024.
 
@@ -262,9 +263,11 @@ def scale_1024(
 
 
 def remap(
-        value: types.DecimalNumber,
-        old_min: types.DecimalNumber, old_max: types.DecimalNumber,
-        new_min: types.DecimalNumber, new_max: types.DecimalNumber,
+    value: types.DecimalNumber,
+    old_min: types.DecimalNumber,
+    old_max: types.DecimalNumber,
+    new_min: types.DecimalNumber,
+    new_max: types.DecimalNumber,
 ) -> types.DecimalNumber:
     '''
     remap a value from one range into another.
@@ -340,19 +343,19 @@ def remap(
     '''
     type_: types.Type[types.DecimalNumber]
     if (
-            isinstance(value, decimal.Decimal) or
-            isinstance(old_min, decimal.Decimal) or
-            isinstance(old_max, decimal.Decimal) or
-            isinstance(new_min, decimal.Decimal) or
-            isinstance(new_max, decimal.Decimal)
+        isinstance(value, decimal.Decimal)
+        or isinstance(old_min, decimal.Decimal)
+        or isinstance(old_max, decimal.Decimal)
+        or isinstance(new_min, decimal.Decimal)
+        or isinstance(new_max, decimal.Decimal)
     ):
         type_ = decimal.Decimal
     elif (
-            isinstance(value, float) or
-            isinstance(old_min, float) or
-            isinstance(old_max, float) or
-            isinstance(new_min, float) or
-            isinstance(new_max, float)
+        isinstance(value, float)
+        or isinstance(old_min, float)
+        or isinstance(old_max, float)
+        or isinstance(new_min, float)
+        or isinstance(new_max, float)
     ):
         type_ = float
 
@@ -369,12 +372,14 @@ def remap(
     new_range = new_max - new_min  # type: ignore
 
     if old_range == 0:
-        raise ValueError('Input range ({}-{}) is empty'.format(
-            old_min, old_max))
+        raise ValueError(
+            'Input range ({}-{}) is empty'.format(old_min, old_max)
+        )
 
     if new_range == 0:
-        raise ValueError('Output range ({}-{}) is empty'.format(
-            new_min, new_max))
+        raise ValueError(
+            'Output range ({}-{}) is empty'.format(new_min, new_max)
+        )
 
     new_value = (value - old_min) * new_range  # type: ignore
 

python_utils/decorators.py

@@ -111,13 +111,20 @@ def sample(sample_rate: float):
     Calls to *demo_function* will be limited to 50% approximatly.
 
     '''
+
     def _sample(function):
         @functools.wraps(function)
         def __sample(*args, **kwargs):
             if random.random() < sample_rate:
                 return function(*args, **kwargs)
             else:
-                logging.debug('Skipped execution of %r(%r, %r) due to sampling', function, args, kwargs)  # noqa: E501
+                logging.debug(
+                    'Skipped execution of %r(%r, %r) due to sampling',
+                    function,
+                    args,
+                    kwargs,
+                )  # noqa: E501
 
         return __sample
+
     return _sample

python_utils/formatters.py

@@ -32,7 +32,7 @@ def camel_to_underscore(name: str) -> str:
             elif i > 3 and not c.isupper():
                 # Will return the last 3 letters to check if we are changing
                 # case
-                previous = name[i - 3:i]
+                previous = name[i - 3 : i]
                 if previous.isalpha() and previous.isupper():
                     output.insert(len(output) - 1, '_')
 
@@ -77,7 +77,7 @@ def apply_recursive(
 
 def timesince(
     dt: types.Union[datetime.datetime, datetime.timedelta],
-    default: str = 'just now'
+    default: str = 'just now',
 ) -> str:
     '''
     Returns string representing 'time since' e.g.