Googleapis Datapipelines

Connector for the googleapis-datapipelines API, generated deterministically from its OpenAPI spec (endpoints, auth, and methods match the spec exactly — nothing is invented).

• Base URL: https://datapipelines.googleapis.com
• Auth: OAuth 2.0 (user-delegated) — attach an InTouch oauth credential. Mint one with itcli.py /oauth <provider> (device-code) or /google-auth (Google); the server auto-refreshes the access token before each run, so the connector never handles or stores tokens.

Operations

• datapipelines_projects_locations_pipelines_get — GET /v1/{name} — Looks up a single pipeline. Returns a "NOT_FOUND" error if no such pipeline exis
• datapipelines_projects_locations_pipelines_jobs_ — GET /v1/{parent}/jobs — Lists jobs for a given pipeline. Throws a "FORBIDDEN" error if the caller doesn'
• datapipelines_projects_locations_pipelines_list — GET /v1/{parent}/pipelines — Lists pipelines. Returns a "FORBIDDEN" error if the caller doesn't have permissi
• datapipelines_projects_locations_pipelines_delet — DELETE /v1/{name} — Deletes a pipeline. If a scheduler job is attached to the pipeline, it will be d
• datapipelines_projects_locations_pipelines_patch — PATCH /v1/{name} — Updates a pipeline. If successful, the updated Pipeline is returned. Returns `NO
• datapipelines_projects_locations_pipelines_run — POST /v1/{name}:run — Creates a job for the specified pipeline directly. You can use this method when

Inputs

• a linked oauth credential (no key inputs) — the server injects a fresh Authorization: Bearer from it
• operation — one of the operations above
• path parameters when an operation's path contains {...}
• query — optional JSON object of query params
• body — JSON object for create/update ops

Example

operation: datapipelines_projects_locations_pipelines_get
# (attach an 'oauth' credential to the task — no inline secrets)