fixes

Author: v1r3n

src/conductor/client/worker/worker_interface.py

@@ -51,7 +51,7 @@ def __init__(self, task_definition_name: Union[str, list]):
         self.thread_count = 1
         self.register_task_def = False
         self.poll_timeout = 100  # milliseconds
-        self.lease_extend_enabled = True
+        self.lease_extend_enabled = False
 
     @abc.abstractmethod
     def execute(self, task: Task) -> TaskResult:

tests/unit/automator/test_task_runner_coverage.py

@@ -32,7 +32,6 @@ class MockWorker(WorkerInterface):
 
     def __init__(self, task_name='test_task'):
         super().__init__(task_name)
-        self.paused = False
         self.poll_interval = 0.01  # Fast polling for tests
 
     def execute(self, task: Task) -> TaskResult:
@@ -283,7 +282,7 @@ def test_run_once_clears_task_definition_name_cache(self):
     def test_poll_task_when_worker_paused(self, mock_sleep):
         """Test polling returns None when worker is paused"""
         worker = MockWorker('test_task')
-        worker.paused_flag = True
+        worker.paused = True
 
         task_runner = TaskRunner(worker=worker)