From d018ef9033d52d68beb1411064a03e7236a78bca Mon Sep 17 00:00:00 2001 From: Yeuoly Date: Thu, 30 Oct 2025 17:11:49 +0800 Subject: [PATCH] apply autofix to autofix CI --- api/core/app/apps/workflow/app_generator.py | 2 +- api/core/app/apps/workflow/app_runner.py | 2 +- api/core/app/apps/workflow_app_runner.py | 2 +- api/core/entities/provider_entities.py | 2 +- api/core/helper/provider_encryption.py | 2 +- api/core/plugin/entities/plugin.py | 2 +- api/core/plugin/entities/request.py | 2 +- api/core/trigger/entities/api_entities.py | 2 +- api/core/trigger/entities/entities.py | 2 +- api/core/workflow/nodes/trigger_plugin/trigger_event_node.py | 2 +- api/core/workflow/nodes/trigger_schedule/entities.py | 2 +- .../workflow/nodes/trigger_schedule/trigger_schedule_node.py | 2 +- api/core/workflow/nodes/trigger_webhook/entities.py | 2 +- api/core/workflow/nodes/trigger_webhook/node.py | 2 +- .../event_handlers/sync_workflow_schedule_when_app_published.py | 2 +- api/libs/schedule_utils.py | 1 - api/models/trigger.py | 2 +- api/repositories/sqlalchemy_workflow_trigger_log_repository.py | 1 - api/repositories/workflow_trigger_log_repository.py | 2 +- api/services/app_generate_service.py | 2 +- api/services/async_workflow_service.py | 2 +- api/services/trigger/schedule_service.py | 2 +- api/services/trigger/trigger_provider_service.py | 2 +- api/services/workflow/entities.py | 2 +- 24 files changed, 22 insertions(+), 24 deletions(-) diff --git a/api/core/app/apps/workflow/app_generator.py b/api/core/app/apps/workflow/app_generator.py index d564182edd..305f6cecd5 100644 --- a/api/core/app/apps/workflow/app_generator.py +++ b/api/core/app/apps/workflow/app_generator.py @@ -3,7 +3,7 @@ import logging import threading import uuid from collections.abc import Generator, Mapping, Sequence -from typing import Any, Literal, Optional, Union, overload +from typing import Any, Literal, Union, overload from flask import Flask, current_app from pydantic import ValidationError diff --git a/api/core/app/apps/workflow/app_runner.py b/api/core/app/apps/workflow/app_runner.py index 328daa9b91..d8460df390 100644 --- a/api/core/app/apps/workflow/app_runner.py +++ b/api/core/app/apps/workflow/app_runner.py @@ -1,7 +1,7 @@ import logging import time from collections.abc import Sequence -from typing import Optional, cast +from typing import cast from core.app.apps.base_app_queue_manager import AppQueueManager from core.app.apps.workflow.app_config_manager import WorkflowAppConfig diff --git a/api/core/app/apps/workflow_app_runner.py b/api/core/app/apps/workflow_app_runner.py index d67451d2c8..0e125b3538 100644 --- a/api/core/app/apps/workflow_app_runner.py +++ b/api/core/app/apps/workflow_app_runner.py @@ -1,6 +1,6 @@ import time from collections.abc import Mapping, Sequence -from typing import Any, Optional, cast +from typing import Any, cast from core.app.apps.base_app_queue_manager import AppQueueManager, PublishFrom from core.app.entities.app_invoke_entities import InvokeFrom diff --git a/api/core/entities/provider_entities.py b/api/core/entities/provider_entities.py index 20e273232e..8a8067332d 100644 --- a/api/core/entities/provider_entities.py +++ b/api/core/entities/provider_entities.py @@ -1,5 +1,5 @@ from enum import StrEnum, auto -from typing import Optional, Union +from typing import Union from pydantic import BaseModel, ConfigDict, Field diff --git a/api/core/helper/provider_encryption.py b/api/core/helper/provider_encryption.py index 58817d2b1c..8484a28c05 100644 --- a/api/core/helper/provider_encryption.py +++ b/api/core/helper/provider_encryption.py @@ -1,7 +1,7 @@ import contextlib from collections.abc import Mapping from copy import deepcopy -from typing import Any, Optional, Protocol +from typing import Any, Protocol from core.entities.provider_entities import BasicProviderConfig from core.helper import encrypter diff --git a/api/core/plugin/entities/plugin.py b/api/core/plugin/entities/plugin.py index 30af4d8a5e..9e1a9edf82 100644 --- a/api/core/plugin/entities/plugin.py +++ b/api/core/plugin/entities/plugin.py @@ -1,7 +1,7 @@ import datetime from collections.abc import Mapping from enum import StrEnum, auto -from typing import Any, Optional +from typing import Any from packaging.version import InvalidVersion, Version from pydantic import BaseModel, Field, field_validator, model_validator diff --git a/api/core/plugin/entities/request.py b/api/core/plugin/entities/request.py index 1ce449cfa6..4385742d34 100644 --- a/api/core/plugin/entities/request.py +++ b/api/core/plugin/entities/request.py @@ -1,7 +1,7 @@ import binascii import json from collections.abc import Mapping -from typing import Any, Literal, Optional +from typing import Any, Literal from flask import Response from pydantic import BaseModel, ConfigDict, Field, field_validator diff --git a/api/core/trigger/entities/api_entities.py b/api/core/trigger/entities/api_entities.py index 6f950f2820..ad7c816144 100644 --- a/api/core/trigger/entities/api_entities.py +++ b/api/core/trigger/entities/api_entities.py @@ -1,5 +1,5 @@ from collections.abc import Mapping -from typing import Any, Optional +from typing import Any from pydantic import BaseModel, Field diff --git a/api/core/trigger/entities/entities.py b/api/core/trigger/entities/entities.py index c4814d767f..46090b5886 100644 --- a/api/core/trigger/entities/entities.py +++ b/api/core/trigger/entities/entities.py @@ -1,7 +1,7 @@ from collections.abc import Mapping from datetime import datetime from enum import StrEnum -from typing import Any, Optional, Union +from typing import Any, Union from pydantic import BaseModel, ConfigDict, Field, ValidationInfo, field_validator diff --git a/api/core/workflow/nodes/trigger_plugin/trigger_event_node.py b/api/core/workflow/nodes/trigger_plugin/trigger_event_node.py index d1990b9632..c4c2ff87db 100644 --- a/api/core/workflow/nodes/trigger_plugin/trigger_event_node.py +++ b/api/core/workflow/nodes/trigger_plugin/trigger_event_node.py @@ -1,5 +1,5 @@ from collections.abc import Mapping -from typing import Any, Optional +from typing import Any from core.workflow.constants import SYSTEM_VARIABLE_NODE_ID from core.workflow.entities.workflow_node_execution import WorkflowNodeExecutionMetadataKey, WorkflowNodeExecutionStatus diff --git a/api/core/workflow/nodes/trigger_schedule/entities.py b/api/core/workflow/nodes/trigger_schedule/entities.py index e09e1867c6..5167103f18 100644 --- a/api/core/workflow/nodes/trigger_schedule/entities.py +++ b/api/core/workflow/nodes/trigger_schedule/entities.py @@ -1,4 +1,4 @@ -from typing import Literal, Optional, Union +from typing import Literal, Union from pydantic import BaseModel, Field diff --git a/api/core/workflow/nodes/trigger_schedule/trigger_schedule_node.py b/api/core/workflow/nodes/trigger_schedule/trigger_schedule_node.py index 824e4e98ad..98a841d1be 100644 --- a/api/core/workflow/nodes/trigger_schedule/trigger_schedule_node.py +++ b/api/core/workflow/nodes/trigger_schedule/trigger_schedule_node.py @@ -1,5 +1,5 @@ from collections.abc import Mapping -from typing import Any, Optional +from typing import Any from core.workflow.constants import SYSTEM_VARIABLE_NODE_ID from core.workflow.entities.workflow_node_execution import WorkflowNodeExecutionStatus diff --git a/api/core/workflow/nodes/trigger_webhook/entities.py b/api/core/workflow/nodes/trigger_webhook/entities.py index df14f6b79d..1011e60b43 100644 --- a/api/core/workflow/nodes/trigger_webhook/entities.py +++ b/api/core/workflow/nodes/trigger_webhook/entities.py @@ -1,6 +1,6 @@ from collections.abc import Sequence from enum import StrEnum -from typing import Literal, Optional +from typing import Literal from pydantic import BaseModel, Field, field_validator diff --git a/api/core/workflow/nodes/trigger_webhook/node.py b/api/core/workflow/nodes/trigger_webhook/node.py index 7ec1825551..15009f90d0 100644 --- a/api/core/workflow/nodes/trigger_webhook/node.py +++ b/api/core/workflow/nodes/trigger_webhook/node.py @@ -1,5 +1,5 @@ from collections.abc import Mapping -from typing import Any, Optional +from typing import Any from core.workflow.constants import SYSTEM_VARIABLE_NODE_ID from core.workflow.entities.workflow_node_execution import WorkflowNodeExecutionStatus diff --git a/api/events/event_handlers/sync_workflow_schedule_when_app_published.py b/api/events/event_handlers/sync_workflow_schedule_when_app_published.py index 912abe1274..168513fc04 100644 --- a/api/events/event_handlers/sync_workflow_schedule_when_app_published.py +++ b/api/events/event_handlers/sync_workflow_schedule_when_app_published.py @@ -1,5 +1,5 @@ import logging -from typing import Optional, cast +from typing import cast from sqlalchemy import select from sqlalchemy.orm import Session diff --git a/api/libs/schedule_utils.py b/api/libs/schedule_utils.py index 4105a8e4c4..1ab5f499e9 100644 --- a/api/libs/schedule_utils.py +++ b/api/libs/schedule_utils.py @@ -1,5 +1,4 @@ from datetime import UTC, datetime -from typing import Optional import pytz from croniter import croniter diff --git a/api/models/trigger.py b/api/models/trigger.py index 9bc57daf1e..c2b66ace46 100644 --- a/api/models/trigger.py +++ b/api/models/trigger.py @@ -3,7 +3,7 @@ import time from collections.abc import Mapping from datetime import datetime from functools import cached_property -from typing import Any, Optional, cast +from typing import Any, cast import sqlalchemy as sa from sqlalchemy import DateTime, Index, Integer, String, UniqueConstraint, func diff --git a/api/repositories/sqlalchemy_workflow_trigger_log_repository.py b/api/repositories/sqlalchemy_workflow_trigger_log_repository.py index c2f8322ac3..0d67e286b0 100644 --- a/api/repositories/sqlalchemy_workflow_trigger_log_repository.py +++ b/api/repositories/sqlalchemy_workflow_trigger_log_repository.py @@ -4,7 +4,6 @@ SQLAlchemy implementation of WorkflowTriggerLogRepository. from collections.abc import Sequence from datetime import UTC, datetime, timedelta -from typing import Optional from sqlalchemy import and_, select from sqlalchemy.orm import Session diff --git a/api/repositories/workflow_trigger_log_repository.py b/api/repositories/workflow_trigger_log_repository.py index d96ecade2b..138b8779ac 100644 --- a/api/repositories/workflow_trigger_log_repository.py +++ b/api/repositories/workflow_trigger_log_repository.py @@ -8,7 +8,7 @@ proper indexing and batch operations. from collections.abc import Sequence from enum import StrEnum -from typing import Optional, Protocol +from typing import Protocol from models.trigger import WorkflowTriggerLog diff --git a/api/services/app_generate_service.py b/api/services/app_generate_service.py index 88449787b3..0d807266a0 100644 --- a/api/services/app_generate_service.py +++ b/api/services/app_generate_service.py @@ -1,6 +1,6 @@ import uuid from collections.abc import Generator, Mapping -from typing import Any, Optional, Union +from typing import Any, Union from configs import dify_config from core.app.apps.advanced_chat.app_generator import AdvancedChatAppGenerator diff --git a/api/services/async_workflow_service.py b/api/services/async_workflow_service.py index 1fbb1fcfda..f54f41a48a 100644 --- a/api/services/async_workflow_service.py +++ b/api/services/async_workflow_service.py @@ -7,7 +7,7 @@ with support for different subscription tiers, rate limiting, and execution trac import json from datetime import UTC, datetime -from typing import Any, Optional, Union +from typing import Any, Union from celery.result import AsyncResult from sqlalchemy import select diff --git a/api/services/trigger/schedule_service.py b/api/services/trigger/schedule_service.py index f4f0a5daf5..d8e85b21d3 100644 --- a/api/services/trigger/schedule_service.py +++ b/api/services/trigger/schedule_service.py @@ -2,7 +2,7 @@ import json import logging from collections.abc import Mapping from datetime import datetime -from typing import Any, Optional +from typing import Any from sqlalchemy import select from sqlalchemy.orm import Session diff --git a/api/services/trigger/trigger_provider_service.py b/api/services/trigger/trigger_provider_service.py index 89e8455e84..371ecd5db8 100644 --- a/api/services/trigger/trigger_provider_service.py +++ b/api/services/trigger/trigger_provider_service.py @@ -3,7 +3,7 @@ import logging import time as _time import uuid from collections.abc import Mapping -from typing import Any, Optional +from typing import Any from sqlalchemy import desc, func from sqlalchemy.orm import Session diff --git a/api/services/workflow/entities.py b/api/services/workflow/entities.py index f80732e092..0074253740 100644 --- a/api/services/workflow/entities.py +++ b/api/services/workflow/entities.py @@ -4,7 +4,7 @@ Pydantic models for async workflow trigger system. from collections.abc import Mapping, Sequence from enum import StrEnum -from typing import Any, Optional +from typing import Any from pydantic import BaseModel, ConfigDict, Field