style: ruff

(ruff and a bit more)

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

Author: ybastide

simpleflow/activity.py

@@ -9,9 +9,9 @@
 
 
 __all__ = [
-    "with_attributes",
-    "Activity",
     "PRIORITY_NOT_SET",
+    "Activity",
+    "with_attributes",
 ]
 
 

simpleflow/process/_supervisor.py

@@ -112,7 +112,7 @@ def _cleanup_worker_processes(self):
                 name, status = child.name(), child.status()
             except psutil.NoSuchProcess:  # May be untimely deceased
                 name, status = "unknown", "unknown"
-            logger.debug("  child: name=%s pid=%d status=%s" % (name, child.pid, status))
+            logger.debug(f"  child: name={name} pid={child.pid:d} status={status}")
             if status in (psutil.STATUS_ZOMBIE, "unknown"):
                 logger.debug(f"  process {child.pid} is zombie, will cleanup")
                 # join process to clean it up

simpleflow/swf/helpers.py

@@ -22,9 +22,9 @@
 
 
 __all__ = [
+    "list_workflow_executions",
     "show_workflow_profile",
     "show_workflow_status",
-    "list_workflow_executions",
     "swf_identity",
 ]
 

simpleflow/swf/mapper/core.py

@@ -37,7 +37,7 @@ def convert_timestamp(dt: int | datetime | None) -> datetime | None:
 class ConnectedSWFObject:
     """Authenticated object interface"""
 
-    __slots__ = ["region", "connection", "boto3_client"]
+    __slots__ = ["boto3_client", "connection", "region"]
 
     region: str
     boto3_client: boto3.client

simpleflow/swf/mapper/models/activity.py

@@ -58,18 +58,18 @@ class ActivityType(BaseModel):
     kind = "type"
 
     __slots__ = [
+        "creation_date",
+        "deprecation_date",
+        "description",
         "domain",
         "name",
-        "version",
         "status",
-        "description",
-        "creation_date",
-        "deprecation_date",
-        "task_list",
         "task_heartbeat_timeout",
+        "task_list",
         "task_schedule_to_close_timeout",
         "task_schedule_to_start_timeout",
         "task_start_to_close_timeout",
+        "version",
     ]
 
     def __init__(
@@ -225,14 +225,14 @@ def __repr__(self):
 @immutable
 class ActivityTask(BaseModel):
     __slots__ = [
+        "activity_id",
+        "activity_type",
         "domain",
+        "input",
+        "started_event_id",
         "task_list",
         "task_token",
-        "activity_type",
         "workflow_execution",
-        "input",
-        "activity_id",
-        "started_event_id",
     ]
 
     # noinspection PyMissingConstructor

simpleflow/swf/mapper/models/domain.py

@@ -40,10 +40,10 @@ class Domain(BaseModel):
     """
 
     __slots__ = [
-        "name",
-        "status",
         "description",
+        "name",
         "retention_period",
+        "status",
     ]
 
     def __init__(

simpleflow/swf/mapper/models/workflow.py

@@ -65,17 +65,17 @@ class WorkflowType(BaseModel):
     """
 
     __slots__ = [
+        "child_policy",
+        "creation_date",
+        "decision_tasks_timeout",
+        "deprecation_date",
+        "description",
         "domain",
+        "execution_timeout",
         "name",
-        "version",
         "status",
-        "creation_date",
-        "deprecation_date",
         "task_list",
-        "child_policy",
-        "execution_timeout",
-        "decision_tasks_timeout",
-        "description",
+        "version",
     ]
 
     def __init__(
@@ -251,7 +251,7 @@ def start_execution(
         :param  decision_tasks_timeout: maximum duration of decision tasks
                                         for this workflow execution
         """
-        workflow_id = workflow_id or "%s-%s-%i" % (self.name, self.version, time.time())
+        workflow_id = workflow_id or f"{self.name}-{self.version}-{time.time():d}"
         task_list = task_list or self.task_list
         child_policy = child_policy or self.child_policy
         if child_policy not in CHILD_POLICIES:
@@ -317,25 +317,25 @@ class WorkflowExecution(BaseModel):
     kind = "execution"
 
     __slots__ = [
-        "domain",
-        "workflow_id",
-        "run_id",
-        "status",
-        "workflow_type",
-        "task_list",
+        "cancel_requested",
         "child_policy",
         "close_status",
+        "close_timestamp",
+        "decision_tasks_timeout",
+        "domain",
         "execution_timeout",
         "input",
-        "tag_list",
-        "decision_tasks_timeout",
-        "close_timestamp",
-        "start_timestamp",
-        "cancel_requested",
-        "latest_execution_context",
         "latest_activity_task_timestamp",
+        "latest_execution_context",
         "open_counts",
         "parent",
+        "run_id",
+        "start_timestamp",
+        "status",
+        "tag_list",
+        "task_list",
+        "workflow_id",
+        "workflow_type",
     ]
 
     def __init__(