refactor: code style

Author: qwejid

src/nats_queue/nats_worker.py

@@ -107,21 +107,21 @@ async def _process_task(self, job: Msg):
                 delay = int(planned_time.total_seconds())
                 await job.nak(delay=delay)
                 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
                     Requeueing in {delay} seconds"""
                 )
                 return
 
             if job_data.get("meta").get("retry_count") > self.max_retries:
                 await job.term()
                 logger.warning(
-                    f"Job: {job_data["name"]} id={job_data["id"]} max retries exceeded"
+                    f"Job: {job_data['name']} id={job_data['id']} max retries exceeded"
                 )
                 return
 
             logger.info(
-                f"""Job: {job_data["name"]} id={job_data["id"]} is started
-                with data={job_data["data"]}) in queue={job_data["queue_name"]}"""
+                f"""Job: {job_data['name']} id={job_data['id']} is started
+                with data={job_data['data']}) in queue={job_data['queue_name']}"""
             )
 
             timeout = job_data["meta"]["timeout"]
@@ -133,7 +133,7 @@ async def _process_task(self, job: Msg):
         except Exception as e:
             if isinstance(e, asyncio.TimeoutError):
                 logger.error(
-                    f"Job: {job_data["name"]} id={job_data["id"]} TimeoutError: {e}"
+                    f"Job: {job_data['name']} id={job_data['id']} TimeoutError: {e}"
                 )
             else:
                 logger.error(f"Error while processing job {job_data['id']}: {e}")