From 82f2f76dc46aa519c540b120dd86687b564c0757 Mon Sep 17 00:00:00 2001 From: hjlarry Date: Wed, 1 Oct 2025 23:39:46 +0800 Subject: [PATCH] ruff format code --- api/controllers/console/app/workflow.py | 15 ++++++--------- api/core/app/apps/workflow/app_runner.py | 2 +- api/core/app/apps/workflow_app_runner.py | 2 +- api/core/trigger/trigger_manager.py | 2 +- api/models/provider_ids.py | 2 +- api/services/plugin/plugin_parameter_service.py | 7 +++---- api/services/tools/tools_transform_service.py | 4 +--- 7 files changed, 14 insertions(+), 20 deletions(-) diff --git a/api/controllers/console/app/workflow.py b/api/controllers/console/app/workflow.py index f804710094..3bd73cde84 100644 --- a/api/controllers/console/app/workflow.py +++ b/api/controllers/console/app/workflow.py @@ -999,17 +999,14 @@ class DraftWorkflowTriggerNodeApi(Resource): @api.doc("poll_draft_workflow_trigger_node") @api.doc(description="Poll for trigger events and execute single node when event arrives") - @api.doc(params={ - "app_id": "Application ID", - "node_id": "Node ID" - }) + @api.doc(params={"app_id": "Application ID", "node_id": "Node ID"}) @api.expect( api.model( "DraftWorkflowTriggerNodeRequest", { "trigger_name": fields.String(required=True, description="Trigger name"), "subscription_id": fields.String(required=True, description="Subscription ID"), - } + }, ) ) @api.response(200, "Trigger event received and node executed successfully") @@ -1087,7 +1084,7 @@ class DraftWorkflowTriggerRunApi(Resource): "node_id": fields.String(required=True, description="Node ID"), "trigger_name": fields.String(required=True, description="Trigger name"), "subscription_id": fields.String(required=True, description="Subscription ID"), - } + }, ) ) @api.response(200, "Trigger event received and workflow executed successfully") @@ -1168,7 +1165,7 @@ class DraftWorkflowTriggerWebhookRunApi(Resource): "DraftWorkflowTriggerWebhookRunRequest", { "node_id": fields.String(required=True, description="Node ID"), - } + }, ) ) @api.response(200, "Workflow executed successfully") @@ -1252,7 +1249,7 @@ class DraftWorkflowTriggerScheduleRunApi(Resource): "DraftWorkflowTriggerScheduleRunRequest", { "node_id": fields.String(required=True, description="Node ID"), - } + }, ) ) @api.response(200, "Workflow executed successfully") @@ -1287,7 +1284,7 @@ class DraftWorkflowTriggerScheduleRunApi(Resource): args=workflow_args, invoke_from=InvokeFrom.DEBUGGER, streaming=True, - root_node_id=node_id + root_node_id=node_id, ) return helper.compact_generate_response(response) except InvokeRateLimitError as ex: diff --git a/api/core/app/apps/workflow/app_runner.py b/api/core/app/apps/workflow/app_runner.py index bf07dbcc52..db5afabebb 100644 --- a/api/core/app/apps/workflow/app_runner.py +++ b/api/core/app/apps/workflow/app_runner.py @@ -90,7 +90,7 @@ class WorkflowAppRunner(WorkflowBasedAppRunner): workflow_id=self._workflow.id, tenant_id=self._workflow.tenant_id, user_id=self.application_generate_entity.user_id, - root_node_id=self._root_node_id + root_node_id=self._root_node_id, ) # RUN WORKFLOW diff --git a/api/core/app/apps/workflow_app_runner.py b/api/core/app/apps/workflow_app_runner.py index 56f460b7a0..906ecaf53f 100644 --- a/api/core/app/apps/workflow_app_runner.py +++ b/api/core/app/apps/workflow_app_runner.py @@ -80,7 +80,7 @@ class WorkflowBasedAppRunner: workflow_id: str = "", tenant_id: str = "", user_id: str = "", - root_node_id: Optional[str] = None + root_node_id: Optional[str] = None, ) -> Graph: """ Init graph diff --git a/api/core/trigger/trigger_manager.py b/api/core/trigger/trigger_manager.py index ff56601e50..0732421e52 100644 --- a/api/core/trigger/trigger_manager.py +++ b/api/core/trigger/trigger_manager.py @@ -126,7 +126,7 @@ class TriggerManager: """ provider = cls.get_trigger_provider(tenant_id, provider_id) return provider.get_events() - + @classmethod def invoke_trigger( cls, diff --git a/api/models/provider_ids.py b/api/models/provider_ids.py index a4171fd65a..0be6a3dc98 100644 --- a/api/models/provider_ids.py +++ b/api/models/provider_ids.py @@ -61,4 +61,4 @@ class DatasourceProviderID(GenericProviderID): class TriggerProviderID(GenericProviderID): def __init__(self, value: str, is_hardcoded: bool = False) -> None: - super().__init__(value, is_hardcoded) \ No newline at end of file + super().__init__(value, is_hardcoded) diff --git a/api/services/plugin/plugin_parameter_service.py b/api/services/plugin/plugin_parameter_service.py index 680bf051f0..b1820e074c 100644 --- a/api/services/plugin/plugin_parameter_service.py +++ b/api/services/plugin/plugin_parameter_service.py @@ -87,10 +87,9 @@ class PluginParameterService: provider_controller = TriggerManager.get_trigger_provider(tenant_id, TriggerProviderID(provider)) subscription: TriggerProviderSubscriptionApiEntity | SubscriptionBuilder | None if credential_id: - subscription = ( - TriggerSubscriptionBuilderService.get_subscription_builder(credential_id) - or TriggerProviderService.get_subscription_by_id(tenant_id, credential_id) - ) + subscription = TriggerSubscriptionBuilderService.get_subscription_builder( + credential_id + ) or TriggerProviderService.get_subscription_by_id(tenant_id, credential_id) else: subscription = TriggerProviderService.get_subscription_by_id(tenant_id) diff --git a/api/services/tools/tools_transform_service.py b/api/services/tools/tools_transform_service.py index b7c7c2417e..3856ccb618 100644 --- a/api/services/tools/tools_transform_service.py +++ b/api/services/tools/tools_transform_service.py @@ -71,9 +71,7 @@ class ToolTransformService: elif isinstance(provider, ToolProviderApiEntity): if provider.plugin_id: if isinstance(provider.icon, str): - provider.icon = PluginService.get_plugin_icon_url( - tenant_id=tenant_id, filename=provider.icon - ) + provider.icon = PluginService.get_plugin_icon_url(tenant_id=tenant_id, filename=provider.icon) if isinstance(provider.icon_dark, str) and provider.icon_dark: provider.icon_dark = PluginService.get_plugin_icon_url( tenant_id=tenant_id, filename=provider.icon_dark