refactor(agent/tools): extract create_task_for_channel from create_escalation_tool

Consolidate the per-channel task dispatch (Action Center vs QuickForm) into a single create_task_for_channel function; create_escalation_task collapses to one call.

Co-Authored-By: Claude Opus 4.8 (1M context) <noreply@anthropic.com>

Author: cotovanu-cristian

src/uipath_langchain/agent/tools/escalation_tool.py

@@ -252,6 +252,58 @@ def _get_exported_trace_id(trace_id: str | None) -> str | None:
     return trace_id
 
 
+async def create_task_for_channel(
+    client: UiPath,
+    channel: EscalationChannel,
+    *,
+    title: str,
+    data: dict[str, Any],
+    recipient: TaskRecipient | None,
+    folder_path: str | None,
+) -> Task:
+    """Create the Action Center or quick-form task backing an escalation channel.
+
+    Quick-form channels (``actionCenterQuickForm``) dispatch to
+    ``create_quickform_async`` with their inline schema; all other channels
+    dispatch to ``create_async`` against the channel's Action Center app.
+    """
+    if isinstance(channel, AgentQuickFormEscalationChannel):
+        schema_id = channel.properties.schema_id
+        if schema_id is None:
+            raise AgentRuntimeError(
+                code=AgentRuntimeErrorCode.TERMINATION_ESCALATION_ERROR,
+                title="Quick form escalation is missing a schema id",
+                detail=(
+                    f"Escalation '{channel.name}' has a quick form "
+                    "schema without a schemaId."
+                ),
+                category=UiPathErrorCategory.USER,
+            )
+        return await client.tasks.create_quickform_async(
+            title=title,
+            task_schema_key=schema_id,
+            schema=channel.properties.form_schema,
+            data=data,
+            folder_path=folder_path,
+            recipient=recipient,
+            priority=channel.priority,
+            labels=channel.labels,
+            is_actionable_message_enabled=channel.properties.is_actionable_message_enabled,
+            actionable_message_metadata=channel.properties.actionable_message_meta_data,
+        )
+    return await client.tasks.create_async(
+        title=title,
+        data=data,
+        app_name=channel.properties.app_name,
+        app_folder_path=folder_path,
+        recipient=recipient,
+        priority=channel.priority,
+        labels=channel.labels,
+        is_actionable_message_enabled=channel.properties.is_actionable_message_enabled,
+        actionable_message_metadata=channel.properties.actionable_message_meta_data,
+    )
+
+
 def create_escalation_tool(
     resource: AgentEscalationResourceConfig,
     agent: LowCodeAgentDefinition | None = None,
@@ -342,42 +394,14 @@ async def escalate(**_tool_kwargs: Any):
             @durable_interrupt
             async def create_escalation_task():
                 client = UiPath()
-                if isinstance(channel, AgentQuickFormEscalationChannel):
-                    schema_id = channel.properties.schema_id
-                    if schema_id is None:
-                        raise AgentRuntimeError(
-                            code=AgentRuntimeErrorCode.TERMINATION_ESCALATION_ERROR,
-                            title="Quick form escalation is missing a schema id",
-                            detail=(
-                                f"Escalation '{resource.name}' has a quick form "
-                                "schema without a schemaId."
-                            ),
-                            category=UiPathErrorCategory.USER,
-                        )
-                    created_task = await client.tasks.create_quickform_async(
-                        title=task_title,
-                        task_schema_key=schema_id,
-                        schema=channel.properties.form_schema,
-                        data=serialized_data,
-                        folder_path=folder_path,
-                        recipient=recipient,
-                        priority=channel.priority,
-                        labels=channel.labels,
-                        is_actionable_message_enabled=channel.properties.is_actionable_message_enabled,
-                        actionable_message_metadata=channel.properties.actionable_message_meta_data,
-                    )
-                else:
-                    created_task = await client.tasks.create_async(
-                        title=task_title,
-                        data=serialized_data,
-                        app_name=app_name,
-                        app_folder_path=folder_path,
-                        recipient=recipient,
-                        priority=channel.priority,
-                        labels=channel.labels,
-                        is_actionable_message_enabled=channel.properties.is_actionable_message_enabled,
-                        actionable_message_metadata=channel.properties.actionable_message_meta_data,
-                    )
+                created_task = await create_task_for_channel(
+                    client,
+                    channel,
+                    title=task_title,
+                    data=serialized_data,
+                    recipient=recipient,
+                    folder_path=folder_path,
+                )
 
                 if created_task.id is not None:
                     _bts_context["task_key"] = str(created_task.id)