refactor: fix with flake8

Author: qwejid

pyproject.toml

@@ -1,6 +1,6 @@
 [tool.poetry]
 name = "nats_queue"
-version = "1.0.7"
+version = "1.1.1"
 description = ""
 authors = ["Kristina Shishkina <k.shishkina@darwinsoft.ru>"]
 readme = "README.md"

src/nats_queue/nats_worker.py

@@ -114,7 +114,7 @@ async def _process_task(self, job: Msg):
                 await job.nak(delay=delay)
                 self.logger.debug(
                     (
-                        f"Job:{job_data['name']} id={job_data['id']} is scheduled later"
+                        f"Job:{job_data['name']} id={job_data['id']} is scheduled later "
                         f"Requeueing in {delay} seconds"
                     )
                 )
@@ -129,7 +129,7 @@ async def _process_task(self, job: Msg):
 
             self.logger.info(
                 (
-                    f"ob: {job_data['name']} id={job_data['id']} is started"
+                    f"ob: {job_data['name']} id={job_data['id']} is started "
                     f"with data={job_data['data']}) in queue={job_data['queue_name']}"
                 )
             )
@@ -174,7 +174,7 @@ async def fetch_messages(
             msgs = await sub.fetch(count, timeout=self.fetch_timeout)
             self.logger.debug(
                 (
-                    f"Consumer: name={(await sub.consumer_info()).name}"
+                    f"Consumer: name={(await sub.consumer_info()).name} "
                     f"fetched {len(msgs)} messages"
                     ""
                 )
@@ -183,15 +183,15 @@ async def fetch_messages(
         except TimeoutError:
             self.logger.debug(
                 (
-                    f"Consumer: name={(await sub.consumer_info()).name}"
+                    f"Consumer: name={(await sub.consumer_info()).name} "
                     f"failed to fetch messages: TimeoutError"
                 )
             )
             return []
         except Exception as e:
             self.logger.error(
                 (
-                    f"Consumer: name={(await sub.consumer_info()).name}"
+                    f"Consumer: name={(await sub.consumer_info()).name} "
                     f"error while fetching messages: {e}"
                 )
             )
@@ -207,14 +207,14 @@ async def get_subscriptions(self) -> List[JetStreamContext.PullSubscription]:
                 )
                 self.logger.info(
                     (
-                        f"Consumer: name={self.name}"
+                        f"Consumer: name={self.name} "
                         f"successfully subscribed to topic {topic}."
                     )
                 )
                 subscriptions.append(sub)
             except Exception as e:
                 self.logger.error(
-                    f"Consumer: name={self.name} error"
+                    f"Consumer: name={self.name} error "
                     f"while subscribing to topic {topic}: {e}"
                 )
                 raise