style: ruff

Signed-off-by: Yves Bastide <yves@botify.com>

Author: ybastide

simpleflow/process/_supervisor.py

@@ -208,7 +208,7 @@ def terminate(self):
         Terminate all worker processes managed by this Supervisor.
         """
         self._terminating = True
-        logger.info("process: will stop workers, this might take up several minutes. " "Please, be patient.")
+        logger.info("process: will stop workers, this might take up several minutes. Please, be patient.")
         self._killall()
 
     def _killall(self):

simpleflow/swf/mapper/querysets/activity.py

@@ -43,7 +43,7 @@ def domain(self, value: Domain):
         from simpleflow.swf.mapper.models.domain import Domain
 
         if not isinstance(value, Domain):
-            err = "domain property has to be of" f"swf.model.domain.Domain type, not {type(value)!r}"
+            err = f"domain property has to be of swf.model.domain.Domain type, not {type(value)!r}"
             raise TypeError(err)
         self._domain = value
 

simpleflow/swf/mapper/querysets/workflow.py

@@ -48,7 +48,7 @@ def domain(self) -> Domain | None:
     @domain.setter
     def domain(self, value: Domain):
         if not isinstance(value, Domain):
-            err = "domain property has to be of" f"swf.model.domain.Domain type, not {type(value)!r}"
+            err = f"domain property has to be of swf.model.domain.Domain type, not {type(value)!r}"
             raise TypeError(err)
         self._domain = value
 

simpleflow/task.py

@@ -102,8 +102,7 @@ def name(self):
 
     def __repr__(self):
         return (
-            f"{self.__class__.__name__}(activity={self.activity}, args={self.args}, kwargs={self.kwargs},"
-            f" id={self.id})"
+            f"{self.__class__.__name__}(activity={self.activity}, args={self.args}, kwargs={self.kwargs}, id={self.id})"
         )
 
     def execute(self):

tests/integration/workflow.py

@@ -34,13 +34,13 @@ def get_uuid(unused=None):
 
 @activity.with_attributes(task_list="quickstart", version="example")
 def increment(x):
-    print("increment: %d" % x)
+    print(f"increment: {x:d}")
     return x + 1
 
 
 @activity.with_attributes(task_list="quickstart", version="example")
 def double(y):
-    print("double: %d" % y)
+    print(f"double: {y:d}")
     return y * 2