fix: lease heartbeat 500 error and remove fork override in tests

src/conductor/client/automator/lease_tracker.py

@@ -20,6 +20,7 @@
 from typing import Any, Dict, Optional
 
 from conductor.client.http.models.task_result import TaskResult
+from conductor.client.http.models.task_result_status import TaskResultStatus
 
 logger = logging.getLogger(__name__)
 
@@ -196,6 +197,7 @@ def _send_heartbeat(info: LeaseInfo) -> None:
             task_id=info.task_id,
             workflow_instance_id=info.workflow_instance_id,
             extend_lease=True,
+            status=TaskResultStatus.IN_PROGRESS,
         )
         for attempt in range(LEASE_EXTEND_RETRY_COUNT):
             try:

tests/integration/workflow/test_workflow_execution.py

@@ -1,6 +1,5 @@
 import logging
 import time
-from multiprocessing import set_start_method
 from time import sleep
 
 from conductor.client.automator.task_handler import TaskHandler
@@ -45,7 +44,6 @@ def run_workflow_execution_tests(configuration: Configuration, workflow_executor
         scan_for_annotated_workers=True,
         import_modules=['tests.integration.resources.worker.python.python_worker']
     )
-    set_start_method('fork', force=True)
     task_handler.start_processes()
     try:
         test_get_workflow_by_correlation_ids(workflow_executor)