Update linting rules

Author: IgorChvyrov-sm

.github/workflows/pull_request.yml

@@ -41,6 +41,7 @@ jobs:
 
   unit-test:
     runs-on: ubuntu-latest
+    needs: lint-code
     env:
       COVERAGE_FILE: coverage.xml
       COVERAGE_DIR: .coverage-reports

.pre-commit-config.yaml

@@ -1,6 +1,10 @@
+# Global exclusions for generated code
+exclude: |
+  (?x)^(src/conductor/client/http/|src/conductor/client/codegen/|src/conductor/client/orkes/api/|src/conductor/asyncio_client/http/)
+
 repos:
   - repo: https://github.com/pre-commit/pre-commit-hooks
-    rev: v5.0.0
+    rev: v6.0.0
     hooks:
       - id: trailing-whitespace
       - id: end-of-file-fixer
@@ -20,14 +24,14 @@ repos:
       - id: poetry-check
       - id: poetry-lock
 
-  - repo: https://github.com/pre-commit/mirrors-mypy
-    rev: v1.15.0
-    hooks:
-      - id: mypy
-        pass_filenames: false
+  # - repo: https://github.com/pre-commit/mirrors-mypy
+  #   rev: v1.15.0
+  #   hooks:
+  #     - id: mypy
+  #       pass_filenames: false
 
   - repo: https://github.com/astral-sh/ruff-pre-commit
-    rev: v0.9.7
+    rev: v0.12.3
     hooks:
       - id: ruff
         args:

README.md

@@ -120,22 +120,22 @@ def main():
     # Connect to Conductor server
     api_config = Configuration()
     workflow_executor = WorkflowExecutor(configuration=api_config)
-    
+
     # Register and create workflow
     workflow = greetings_workflow(workflow_executor)
     workflow.register(True)
-    
+
     # Start workers
     task_handler = TaskHandler(configuration=api_config)
     task_handler.start_processes()
-    
+
     # Execute workflow
     workflow_run = workflow_executor.execute(
-        name=workflow.name, 
+        name=workflow.name,
         version=workflow.version,
         workflow_input={'name': 'Orkes'}
     )
-    
+
     print(f'Workflow result: {workflow_run.output["result"]}')
     task_handler.stop_processes()
 

RELEASE.md

@@ -85,4 +85,4 @@ This is the final step that triggers the deployment pipeline.
 
 - Pushing the tag will trigger the "Release" workflow in GitHub Actions.
 - Monitor the workflow to ensure it completes successfully.
-- Once the workflow is finished, navigate to the project's page on [PyPI](https://pypi.org/project/conductor-python/) to verify that the new version has been published. 
+- Once the workflow is finished, navigate to the project's page on [PyPI](https://pypi.org/project/conductor-python/) to verify that the new version has been published.

conductor_apps.md

@@ -78,4 +78,4 @@ Here is a recommended approach when defining workflows using JSON:
 A powerful feature of Conductor is the ability to version workflows. You should increment the version of the workflow when there is a significant change to the definition. You can run multiple versions of the workflow at the same time. When starting a new workflow execution, use the `version` field to specify which version to use. When omitted, the latest (highest-numbered) version is used.
 
 * Versioning allows safely testing changes by doing canary testing in production or A/B testing across multiple versions before rolling out.
-* A version can also be deleted, effectively allowing for "rollback" if required.
+* A version can also be deleted, effectively allowing for "rollback" if required.

docs/authentication-retry-policy.md

@@ -146,16 +146,16 @@ async def main():
         auth_401_max_attempts=3,
         auth_401_base_delay_ms=500.0
     )
-    
+
     workflow_client = WorkflowClient(config)
-    
+
     # The retry policy is automatically applied to all API calls
     workflow = await workflow_client.start_workflow(
         name="my_workflow",
         version=1,
         input={"key": "value"}
     )
-    
+
     print(f"Started workflow: {workflow.workflow_id}")
 
 asyncio.run(main())
@@ -203,17 +203,17 @@ async def start_multiple_workflows():
         auth_key="your_key",
         auth_secret="your_secret"
     )
-    
+
     workflow_client = WorkflowClient(config)
-    
+
     # Start multiple workflows concurrently
     # If all receive 401, only one token refresh will occur
     tasks = [
         workflow_client.start_workflow(name="workflow1", version=1, input={}),
         workflow_client.start_workflow(name="workflow2", version=1, input={}),
         workflow_client.start_workflow(name="workflow3", version=1, input={})
     ]
-    
+
     results = await asyncio.gather(*tasks)
     return results
 

docs/configuration/proxy.md

@@ -193,12 +193,12 @@ async def main():
             "https://": "http://proxy.company.com:8080"
         }
     )
-    
+
     config = Configuration(
         server_url="https://api.orkes.io/api",
         http_connection=async_client
     )
-    
+
     async with ApiClient(config) as api_client:
         # Use the client with proxy configuration
         pass

docs/configuration/ssl-tls.md

@@ -77,7 +77,7 @@ import ssl
 ssl_context = ssl.create_default_context()
 ssl_context.load_verify_locations("/path/to/ca-certificate.pem")
 ssl_context.load_cert_chain(
-    certfile="/path/to/client-certificate.pem", 
+    certfile="/path/to/client-certificate.pem",
     keyfile="/path/to/client-key.pem"
 )
 
@@ -113,7 +113,7 @@ async def main():
     async with ApiClient(config) as api_client:
         orkes_clients = OrkesClients(api_client, config)
         workflow_client = orkes_clients.get_workflow_client()
-        
+
         # Use the client with SSL configuration
         workflows = await workflow_client.search_workflows()
         print(f"Found {len(workflows)} workflows")
@@ -144,7 +144,7 @@ import ssl
 ssl_context = ssl.create_default_context()
 ssl_context.load_verify_locations("/path/to/ca-certificate.pem")
 ssl_context.load_cert_chain(
-    certfile="/path/to/client-certificate.pem", 
+    certfile="/path/to/client-certificate.pem",
     keyfile="/path/to/client-key.pem"
 )
 ssl_context.check_hostname = True
@@ -251,7 +251,7 @@ import socket
 def test_ssl_connection(hostname, port, ca_cert_path):
     context = ssl.create_default_context()
     context.load_verify_locations(ca_cert_path)
-    
+
     with socket.create_connection((hostname, port)) as sock:
         with context.wrap_socket(sock, server_hostname=hostname) as ssock:
             print(f"SSL connection successful: {ssock.version()}")

docs/development/README.md

@@ -79,7 +79,7 @@ Both guides include detailed troubleshooting sections, best practices, and step-
    ```bash
    # For sync client
    python scripts/generate_swagger.py --version 3.15.0 --output src/conductor/client/swagger.json
-   
+
    # For async client
    python scripts/generate_swagger.py --version 3.15.0 --output src/conductor/asyncio_client/swagger.json
    ```
@@ -88,7 +88,7 @@ Both guides include detailed troubleshooting sections, best practices, and step-
    ```bash
    # Sync client
    swagger-codegen generate -i src/conductor/client/swagger.json -l python -o src/conductor/client/codegen/
-   
+
    # Async client
    openapi-generator generate -i src/conductor/asyncio_client/swagger.json -g python -o src/conductor/asyncio_client/http/
    ```
@@ -150,7 +150,7 @@ def test_worker_task_execution():
     @worker_task(task_definition_name='test_task')
     def test_task(input_data: str) -> str:
         return f"processed: {input_data}"
-    
+
     result = test_task("test_input")
     assert result == "processed: test_input"
 ```

docs/development/workflow_usage_examples.md

@@ -159,7 +159,7 @@ print(not_found)  # None
 ```python
 def monitor_workflow_status(workflow: Workflow):
     """Monitor and report workflow status"""
-    
+
     if workflow.is_completed():
         if workflow.is_successful():
             print("Workflow completed successfully!")
@@ -169,16 +169,16 @@ def monitor_workflow_status(workflow: Workflow):
             return "FAILED"
     elif workflow.is_running():
         print("Workflow is still running...")
-        
+
         # Check current task
         current = workflow.current_task
         if current:
             print(f"Current task: {current.task_def_name} ({current.status})")
-        
+
         # Get all in-progress tasks
         in_progress = workflow.get_in_progress_tasks()
         print(f"Total in-progress tasks: {len(in_progress)}")
-        
+
         return "RUNNING"
     else:
         print("Unknown workflow status")
@@ -194,16 +194,16 @@ status = monitor_workflow_status(workflow)
 ```python
 def track_task_progress(workflow: Workflow):
     """Track progress of specific tasks in a workflow"""
-    
+
     # Get all in-progress tasks
     in_progress_tasks = workflow.get_in_progress_tasks()
-    
+
     print(f"Workflow Status: {workflow.status}")
     print(f"Total in-progress tasks: {len(in_progress_tasks)}")
-    
+
     for task in in_progress_tasks:
         print(f"- {task.task_def_name}: {task.status}")
-        
+
         # If task has a reference name, show it
         if hasattr(task, 'workflow_task') and task.workflow_task:
             ref_name = getattr(task.workflow_task, 'task_reference_name', 'N/A')
@@ -219,39 +219,39 @@ track_task_progress(workflow)
 ```python
 def process_workflow_result(workflow: Workflow):
     """Process workflow results based on completion status"""
-    
+
     if not workflow.is_completed():
         print("Workflow is not yet completed")
         return None
-    
+
     if workflow.is_successful():
         print("Processing successful workflow result...")
-        
+
         # Get workflow output
         if workflow.output:
             print(f"Workflow output: {workflow.output}")
-        
+
         # Find specific tasks by reference name
         result_task = workflow.get_task_by_reference_name("process_result")
         if result_task:
             print(f"Result task status: {result_task.status}")
             if hasattr(result_task, 'output_data') and result_task.output_data:
                 print(f"Task output: {result_task.output_data}")
-        
+
         return workflow.output
-    
+
     else:
         print("Processing failed workflow...")
-        
+
         # Get failed tasks
         failed_tasks = [task for task in workflow.tasks if task.status == "FAILED"]
         print(f"Number of failed tasks: {len(failed_tasks)}")
-        
+
         for task in failed_tasks:
             print(f"Failed task: {task.task_def_name}")
             if hasattr(task, 'reason_for_incompletion'):
                 print(f"Reason: {task.reason_for_incompletion}")
-        
+
         return None
 
 # Usage
@@ -264,7 +264,7 @@ result = process_workflow_result(workflow)
 ```python
 def health_check_workflow(workflow: Workflow) -> dict:
     """Perform a comprehensive health check on a workflow"""
-    
+
     health_status = {
         "workflow_id": getattr(workflow, 'workflow_id', 'unknown'),
         "status": workflow.status,
@@ -276,19 +276,19 @@ def health_check_workflow(workflow: Workflow) -> dict:
         "in_progress_count": 0,
         "total_tasks": 0
     }
-    
+
     # Task information
     if workflow.tasks:
         health_status["total_tasks"] = len(workflow.tasks)
         health_status["in_progress_count"] = len(workflow.get_in_progress_tasks())
-        
+
         current = workflow.current_task
         if current:
             health_status["current_task"] = {
                 "name": current.task_def_name,
                 "status": current.status
             }
-    
+
     # Overall health assessment
     if workflow.is_successful():
         health_status["health"] = "HEALTHY"
@@ -298,7 +298,7 @@ def health_check_workflow(workflow: Workflow) -> dict:
         health_status["health"] = "IN_PROGRESS"
     else:
         health_status["health"] = "UNKNOWN"
-    
+
     return health_status
 
 # Usage
@@ -335,7 +335,7 @@ print(workflow.current_task)  # None or current task
 ```python
 def comprehensive_workflow_check(workflow: WorkflowAdapter):
     """Comprehensive workflow state checking"""
-    
+
     if workflow.is_completed():
         if workflow.is_successful():
             return "SUCCESS"