* Get user preferences from database or existing preference json config.

* Get workflow execution detail with node executions * @param user - The user requesting the workflow detail * @param executionId - The workflow

* Proactively initialize connections to all servers. This will be called automatically when * methods requiring an active connection (like {@link g

* Initialize workflow execution - entry method * @param user - The user to create the workflow for * @param sourceCanvasId - The canvas ID *

* Check if Langfuse monitoring is enabled

* Lazy load daily gift credits for user if needed * This method first checks if there's already a gift credit recharge for today, * then checks

* List user tools for mention list * Returns installed tools (authorized) and uninstalled external OAuth tools (unauthorized)

* Core load function

* Mark a job as failed

* Patch an existing workflow plan using semantic operations (create a new version with changes) * @param planId - The ID of the workflow plan to pa

* Poll one workflow execution: enqueue ready waiting nodes and decide whether to requeue a poll.

* Get a presigned URL for downloading an object * @param key The storage key * @param expiresIn The expiration time in seconds * @returns A p

* Publish a drive file to public OSS for sharing * Copies the file from internal OSS to external OSS and returns the public URL * Creates a new

* Perform PUT request

* Render all steps

* Replace all fileIds in a JSON string * FileId format: df-{24 char cuid2}

* Resolve inventory keys to GenericToolset objects for CLI usage. * Accepts inventory keys (e.g., 'tavily', 'fal_audio') and resolves them to *

* Search a document from the search index * @param user The document owner * @param index The index name * @param query The query string *

* Send task message to SQS

* Start the spinner

* Stop the spinner without status