Function api_execute

plugin/app/routes/execute.py:107–140

(
    data: RunToolRequest,
)

    response_model=Union[RunToolResponse, BaseDataResponse],
)
async def api_execute(
    data: RunToolRequest,
):
    plugin: PluginHandler = get_plugin_handler(
        bundle_id=data.bundle_id,
        plugin_id=data.plugin_id,
    )
    if not plugin:
        raise_http_error(ErrorCode.OBJECT_NOT_FOUND, f"Plugin {data.plugin_id} not found")

    cleaned_dict = {k: v for k, v in data.input_params.items() if v is not None}
    data.input_params = cleaned_dict

    try:
        plugin_output = await plugin.execute(
            credentials=data.credentials,
            plugin_input=PluginInput(input_params=data.input_params, project_id=data.project_id),
        )
    except TKHttpException as e:
        logger.error(f"api_execute: {data.bundle_id}/{data.plugin_id}. Input params: {data.input_params}. Error: {e}")
        return BaseDataResponse(
            data={
                "status": e.status_code,
                "data": {
                    "error": e.detail.get("message", "Error when handling response from provider"),
                },
            }
        )
    except Exception as e:
        raise_http_error(ErrorCode.INTERNAL_SERVER_ERROR, str(e))

    return RunToolResponse(
        data=plugin_output,
    )