lint

Signed-off-by: Filinto Duran <[email protected]>

Author: filintod

durabletask/client.py

@@ -230,7 +230,9 @@ def wait_for_orchestration_completion(
                 current_state = self.get_orchestration_state(
                     instance_id, fetch_payloads=fetch_payloads
                 )
-                if current_state and helpers.is_orchestration_terminal_status(current_state.runtime_status):
+                if current_state and helpers.is_orchestration_terminal_status(
+                    current_state.runtime_status
+                ):
                     return current_state
 
                 # Poll for completion with exponential backoff to handle eventual consistency
@@ -243,7 +245,9 @@ def wait_for_orchestration_completion(
                         instance_id, fetch_payloads=fetch_payloads
                     )
 
-                    if current_state and helpers.is_orchestration_terminal_status(current_state.runtime_status):
+                    if current_state and helpers.is_orchestration_terminal_status(
+                        current_state.runtime_status
+                    ):
                         return current_state
 
                     time.sleep(poll_interval)

durabletask/worker.py

@@ -6,8 +6,6 @@
 import logging
 import os
 import random
-import threading
-import time
 from concurrent.futures import ThreadPoolExecutor
 from datetime import datetime, timedelta
 from threading import Event, Thread