Fix ruff issues after merge

Author: IgorChvyrov-sm

src/conductor/shared/worker/__init__.py

@@ -11,7 +11,7 @@
 __all__ = [
     "NonRetryableException",
     "TaskOptions",
-    "task_options",
-    "get_task_options",
     "apply_task_options_to_task_def",
+    "get_task_options",
+    "task_options",
 ]

src/conductor/shared/worker/task_definition_helper.py

@@ -35,9 +35,7 @@ def apply_task_options_to_task_def(task_def, task_options: TaskOptions) -> None:
         task_def.rate_limit_per_frequency = task_options.rate_limit_per_frequency
 
     if task_options.rate_limit_frequency_in_seconds is not None:
-        task_def.rate_limit_frequency_in_seconds = (
-            task_options.rate_limit_frequency_in_seconds
-        )
+        task_def.rate_limit_frequency_in_seconds = task_options.rate_limit_frequency_in_seconds
 
     if task_options.concurrent_exec_limit is not None:
         task_def.concurrent_exec_limit = task_options.concurrent_exec_limit

src/conductor/shared/worker/task_options.py

@@ -98,10 +98,7 @@ def _validate_parameters(
         if rate_limit_per_frequency is not None and rate_limit_per_frequency < 0:
             raise ValueError("rate_limit_per_frequency must be >= 0")
 
-        if (
-            rate_limit_frequency_in_seconds is not None
-            and rate_limit_frequency_in_seconds < 0
-        ):
+        if rate_limit_frequency_in_seconds is not None and rate_limit_frequency_in_seconds < 0:
             raise ValueError("rate_limit_frequency_in_seconds must be >= 0")
 
         if concurrent_exec_limit is not None and concurrent_exec_limit < 0:
@@ -133,9 +130,7 @@ def to_dict(self):
         if self.rate_limit_per_frequency is not None:
             result["rate_limit_per_frequency"] = self.rate_limit_per_frequency
         if self.rate_limit_frequency_in_seconds is not None:
-            result["rate_limit_frequency_in_seconds"] = (
-                self.rate_limit_frequency_in_seconds
-            )
+            result["rate_limit_frequency_in_seconds"] = self.rate_limit_frequency_in_seconds
         if self.concurrent_exec_limit is not None:
             result["concurrent_exec_limit"] = self.concurrent_exec_limit
         if self.timeout_policy is not None: