{"record":{"id":"65be53861d947c6d","repo":"influxdata/influxdb","slug":"invalid-endpoint-url","errorCode":null,"errorMessage":"Invalid endpoint: {url}","messagePattern":"Invalid endpoint: (.+?)","errorType":"validation","errorClass":"InvalidEndpoint","httpStatus":null,"severity":"error","filePath":"core/catalog_cache/src/api/client.rs","lineNumber":81,"sourceCode":"    put_request_timeout: Duration,\n    list_request_timeout: Duration,\n    endpoint: Url,\n    registry: Arc<metric::Registry>,\n}\n\nimpl CatalogCacheClientBuilder {\n    /// Build client.\n    pub fn build(self) -> Result<CatalogCacheClient> {\n        let Self {\n            connect_timeout,\n            get_request_timeout,\n            put_request_timeout,\n            list_request_timeout,\n            endpoint,\n            registry,\n        } = self;\n\n        ensure!(\n            endpoint.path().is_empty() || endpoint.path() == \"/\",\n            InvalidEndpointSnafu {\n                url: endpoint.clone()\n            },\n        );\n        ensure!(\n            endpoint.query().is_none(),\n            InvalidEndpointSnafu {\n                url: endpoint.clone()\n            },\n        );\n        ensure!(\n            endpoint.fragment().is_none(),\n            InvalidEndpointSnafu {\n                url: endpoint.clone()\n            },\n        );\n","sourceCodeStart":63,"sourceCodeEnd":99,"githubUrl":"https://github.com/influxdata/influxdb/blob/06200ef96ba82c5f6727e5038a83af8e722c6875/core/catalog_cache/src/api/client.rs#L63-L99","documentation":"ProcessingEngineError::TriggerNotFound is raised when the processing engine manager cannot find a trigger with the given TriggerId registered under the given database (DbId). The library throws it during trigger lookup/operations (e.g. enable/disable/delete or fetch) when the trigger identifier supplied does not exist in that database. It means the caller referenced a trigger that was never created or has since been removed.","triggerScenarios":"Calling ProcessingEngineManager methods that take a trigger_id and db_id (e.g. disabling, enabling, deleting, or fetching a trigger) when no trigger with that TriggerId is registered for that database in the catalog.","commonSituations":"Typo'd trigger name/ID from a CLI command or HTTP API call; the trigger was deleted on another node; querying the wrong database; the trigger definition was dropped after a catalog migration or restart.","solutions":["List the existing triggers for the database (catalog/API) and confirm the exact trigger_id before retrying.","Verify you are targeting the correct database (db_id); triggers are scoped per database.","If the trigger should exist, re-create it with the processing engine trigger creation API/`CREATE TRIGGER`.","Check whether the trigger was deleted (e.g. by another process or `DROP TRIGGER`) and re-register it."],"exampleFix":"// before\nmanager.disable_trigger(db_id, trigger_id).await?;\n// after\nmatch manager.get_trigger(db_id, &trigger_id) {\n    Some(_) => manager.disable_trigger(db_id, trigger_id).await?,\n    None => eprintln!(\"trigger {trigger_id} does not exist in {db_id}; create it first\"),\n}","handlingStrategy":"try-catch","validationCode":"let exists = list_triggers(db_id).await?.iter().any(|t| t.id == trigger_id);\nif !exists { return Err(format!(\"trigger {trigger_id} missing in {db_id}\")); }","typeGuard":"fn trigger_exists(triggers: &[Trigger], id: TriggerId) -> bool { triggers.iter().any(|t| t.id == id) }","tryCatchPattern":"match res {\n    Err(ProcessingEngineError::TriggerNotFound { db_id, trigger_id }) => warn!(\"trigger {trigger_id:?} absent in {db_id:?}, skipping\"),\n    Err(e) => return Err(e),\n    Ok(v) => v,\n}","preventionTips":["Always resolve trigger IDs from a list/get call instead of hardcoding them.","Scope operations to the same db_id the trigger was created with.","Re-check trigger existence after restarts or catalog migrations."],"tags":["processing-engine","trigger","not-found","influxdb3"],"backgroundTag":"entity-not-found","analyzedSha":"06200ef96ba82c5f6727e5038a83af8e722c6875","analyzedAt":"2026-09-19T12:55:30.003Z","contentChangedAt":"2026-09-19T12:55:30.003Z","schemaVersion":2},"datasetVersion":"2026-09-23T08:17:48.524Z"}