Merge branch 'release/0.2.0'

Author: s3rius

.flake8

@@ -91,15 +91,6 @@ ignore =
   ; Do not perform function calls in argument defaults.
   B008,
 
-  ; all init files
-  __init__.py:
-  ; ignore not used imports
-  F401,
-  ; ignore import with wildcard
-  F403,
-  ; Found wrong metadata variable
-  WPS410,
-
 per-file-ignores =
   ; all tests
   test_*.py,tests.py,tests_*.py,*/tests/*:
@@ -114,6 +105,15 @@ per-file-ignores =
   ; Found complex default value
   WPS404,
 
+  ; all init files
+  __init__.py:
+  ; ignore not used imports
+  F401,
+  ; ignore import with wildcard
+  F403,
+  ; Found wrong metadata variable
+  WPS410,
+
 exclude =
   ./.git,
   ./venv,

README.md

@@ -1,6 +1,6 @@
 # taskiq-memphis
 
-This library provides you with memphis broker for taskiq.  
+This library provides you with memphis broker for taskiq.
 **You need python version >=3.8**
 
 ### Usage:
@@ -26,7 +26,7 @@ MemphisBroker parameters:
 * `port` - memphis server port.
 * `username` - username.
 * `connection_token` - connection token.
-* `password` - password for username. 
+* `password` - password for username.
 * `result_backend` - custom result backend.
 * `task_id_generator` - custom task_id genertaor.
 * `reconnect` - turn on/off reconnection while connection is lost.
@@ -77,11 +77,11 @@ Memphis `station` parameters you can configure:
 * `schema_name` - name of the schema. (You can create it only via memphis UI now)
 * `send_poison_msg_to_dls` - send poisoned message to dead letter station or not.
 * `send_schema_failed_msg_to_dls` - send schema failed message to dead letter station or not.
-* `tiered_storage_enabled` - tiered storage enabled or not.  
-  
+* `tiered_storage_enabled` - tiered storage enabled or not.
+
 Memphis `producer` parameters you can configure:
 * `producer_name` - producer name. Required.
-* `generate_random_suffix` - add suffix to producer name. Default - `True`.  
+* `generate_random_suffix` - add suffix to producer name. Default - `True`.
 **DON'T SET THIS VARIABLE TO `FALSE` IF YOU WANT TO USE MORE THAN ONE PRODUCER.**
 
 Memphis `produce` method parameters you can configure:
@@ -98,7 +98,7 @@ Memphis `consumer` parameters you can configure:
 * `batch_max_time_to_wait_ms` - max time in milliseconds to wait between pulls.
 * `max_ack_time_ms` - max time for ack a message in milliseconds.
 * `max_msg_deliveries` - max number of message deliveries.
-* `generate_random_suffix` - concatenate a random suffix to consumer's name.  
+* `generate_random_suffix` - concatenate a random suffix to consumer's name.
 **DON'T SET THIS VARIABLE TO `FALSE` IF YOU WANT TO USE MORE THAN ONE CONSUMER.**
 * `start_consume_from_sequence` - start consuming from a specific sequence.
 * `last_messages` - consume the last N messages.