1. Packages
  2. Packages
  3. Cloudflare Provider
  4. API Docs
  5. getPipeline
Viewing docs for Cloudflare v6.15.0
published on Saturday, May 2, 2026 by Pulumi
Schema (JSON)
pulumi/pulumi-cloudflare

cloudflare.getPipeline

cloudflare logo
Viewing docs for Cloudflare v6.15.0
published on Saturday, May 2, 2026 by Pulumi
Schema (JSON)
pulumi/pulumi-cloudflare

    Accepted Permissions

    • Pipelines Read
    • Pipelines Write

    Example Usage

    import * as pulumi from "@pulumi/pulumi";
import * as cloudflare from "@pulumi/cloudflare";

const examplePipeline = cloudflare.getPipeline({
    accountId: "0123105f4ecef8ad9ca31a8372d0c353",
    pipelineId: "043e105f4ecef8ad9ca31a8372d0c353",
});

    import pulumi
import pulumi_cloudflare as cloudflare

example_pipeline = cloudflare.get_pipeline(account_id="0123105f4ecef8ad9ca31a8372d0c353",
    pipeline_id="043e105f4ecef8ad9ca31a8372d0c353")

    package main

import (
	"github.com/pulumi/pulumi-cloudflare/sdk/v6/go/cloudflare"
	"github.com/pulumi/pulumi/sdk/v3/go/pulumi"
)

func main() {
	pulumi.Run(func(ctx *pulumi.Context) error {
		_, err := cloudflare.GetPipeline(ctx, &cloudflare.LookupPipelineArgs{
			AccountId:  pulumi.StringRef("0123105f4ecef8ad9ca31a8372d0c353"),
			PipelineId: "043e105f4ecef8ad9ca31a8372d0c353",
		}, nil)
		if err != nil {
			return err
		}
		return nil
	})
}

    using System.Collections.Generic;
using System.Linq;
using Pulumi;
using Cloudflare = Pulumi.Cloudflare;

return await Deployment.RunAsync(() => 
{
    var examplePipeline = Cloudflare.Index.GetPipeline.Invoke(new()
    {
        AccountId = "0123105f4ecef8ad9ca31a8372d0c353",
        PipelineId = "043e105f4ecef8ad9ca31a8372d0c353",
    });

});

    package generated_program;

import com.pulumi.Context;
import com.pulumi.Pulumi;
import com.pulumi.core.Output;
import com.pulumi.cloudflare.CloudflareFunctions;
import com.pulumi.cloudflare.inputs.GetPipelineArgs;
import java.util.List;
import java.util.ArrayList;
import java.util.Map;
import java.io.File;
import java.nio.file.Files;
import java.nio.file.Paths;

public class App {
    public static void main(String[] args) {
        Pulumi.run(App::stack);
    }

    public static void stack(Context ctx) {
        final var examplePipeline = CloudflareFunctions.getPipeline(GetPipelineArgs.builder()
            .accountId("0123105f4ecef8ad9ca31a8372d0c353")
            .pipelineId("043e105f4ecef8ad9ca31a8372d0c353")
            .build());

    }
}

    variables:
  examplePipeline:
    fn::invoke:
      function: cloudflare:getPipeline
      arguments:
        accountId: 0123105f4ecef8ad9ca31a8372d0c353
        pipelineId: 043e105f4ecef8ad9ca31a8372d0c353

    Using getPipeline

    Two invocation forms are available. The direct form accepts plain arguments and either blocks until the result value is available, or returns a Promise-wrapped result. The output form accepts Input-wrapped arguments and returns an Output-wrapped result.

    function getPipeline(args: GetPipelineArgs, opts?: InvokeOptions): Promise<GetPipelineResult>
function getPipelineOutput(args: GetPipelineOutputArgs, opts?: InvokeOptions): Output<GetPipelineResult>
    def get_pipeline(account_id: Optional[str] = None,
                 pipeline_id: Optional[str] = None,
                 opts: Optional[InvokeOptions] = None) -> GetPipelineResult
def get_pipeline_output(account_id: Optional[pulumi.Input[str]] = None,
                 pipeline_id: Optional[pulumi.Input[str]] = None,
                 opts: Optional[InvokeOptions] = None) -> Output[GetPipelineResult]
    func LookupPipeline(ctx *Context, args *LookupPipelineArgs, opts ...InvokeOption) (*LookupPipelineResult, error)
func LookupPipelineOutput(ctx *Context, args *LookupPipelineOutputArgs, opts ...InvokeOption) LookupPipelineResultOutput

    > Note: This function is named LookupPipeline in the Go SDK.

    public static class GetPipeline 
{
    public static Task<GetPipelineResult> InvokeAsync(GetPipelineArgs args, InvokeOptions? opts = null)
    public static Output<GetPipelineResult> Invoke(GetPipelineInvokeArgs args, InvokeOptions? opts = null)
}
    public static CompletableFuture<GetPipelineResult> getPipeline(GetPipelineArgs args, InvokeOptions options)
public static Output<GetPipelineResult> getPipeline(GetPipelineArgs args, InvokeOptions options)

    fn::invoke:
  function: cloudflare:index/getPipeline:getPipeline
  arguments:
    # arguments dictionary

    The following arguments are supported:

    PipelineId string
    Specifies the public ID of the pipeline.
    AccountId string
    Specifies the public ID of the account.
    PipelineId string
    Specifies the public ID of the pipeline.
    AccountId string
    Specifies the public ID of the account.
    pipelineId String
    Specifies the public ID of the pipeline.
    accountId String
    Specifies the public ID of the account.
    pipelineId string
    Specifies the public ID of the pipeline.
    accountId string
    Specifies the public ID of the account.
    pipeline_id str
    Specifies the public ID of the pipeline.
    account_id str
    Specifies the public ID of the account.
    pipelineId String
    Specifies the public ID of the pipeline.
    accountId String
    Specifies the public ID of the account.

    getPipeline Result

    The following output properties are available:

    CreatedAt string
    FailureReason string
    Indicates the reason for the failure of the Pipeline.
    Id string
    Specifies the public ID of the pipeline.
    ModifiedAt string
    Name string
    Indicates the name of the Pipeline.
    PipelineId string
    Specifies the public ID of the pipeline.
    Sql string
    Specifies SQL for the Pipeline processing flow.
    Status string
    Indicates the current status of the Pipeline.
    Tables List<GetPipelineTable>
    List of streams and sinks used by this pipeline.
    AccountId string
    Specifies the public ID of the account.
    CreatedAt string
    FailureReason string
    Indicates the reason for the failure of the Pipeline.
    Id string
    Specifies the public ID of the pipeline.
    ModifiedAt string
    Name string
    Indicates the name of the Pipeline.
    PipelineId string
    Specifies the public ID of the pipeline.
    Sql string
    Specifies SQL for the Pipeline processing flow.
    Status string
    Indicates the current status of the Pipeline.
    Tables []GetPipelineTable
    List of streams and sinks used by this pipeline.
    AccountId string
    Specifies the public ID of the account.
    createdAt String
    failureReason String
    Indicates the reason for the failure of the Pipeline.
    id String
    Specifies the public ID of the pipeline.
    modifiedAt String
    name String
    Indicates the name of the Pipeline.
    pipelineId String
    Specifies the public ID of the pipeline.
    sql String
    Specifies SQL for the Pipeline processing flow.
    status String
    Indicates the current status of the Pipeline.
    tables List<GetPipelineTable>
    List of streams and sinks used by this pipeline.
    accountId String
    Specifies the public ID of the account.
    createdAt string
    failureReason string
    Indicates the reason for the failure of the Pipeline.
    id string
    Specifies the public ID of the pipeline.
    modifiedAt string
    name string
    Indicates the name of the Pipeline.
    pipelineId string
    Specifies the public ID of the pipeline.
    sql string
    Specifies SQL for the Pipeline processing flow.
    status string
    Indicates the current status of the Pipeline.
    tables GetPipelineTable[]
    List of streams and sinks used by this pipeline.
    accountId string
    Specifies the public ID of the account.
    created_at str
    failure_reason str
    Indicates the reason for the failure of the Pipeline.
    id str
    Specifies the public ID of the pipeline.
    modified_at str
    name str
    Indicates the name of the Pipeline.
    pipeline_id str
    Specifies the public ID of the pipeline.
    sql str
    Specifies SQL for the Pipeline processing flow.
    status str
    Indicates the current status of the Pipeline.
    tables Sequence[GetPipelineTable]
    List of streams and sinks used by this pipeline.
    account_id str
    Specifies the public ID of the account.
    createdAt String
    failureReason String
    Indicates the reason for the failure of the Pipeline.
    id String
    Specifies the public ID of the pipeline.
    modifiedAt String
    name String
    Indicates the name of the Pipeline.
    pipelineId String
    Specifies the public ID of the pipeline.
    sql String
    Specifies SQL for the Pipeline processing flow.
    status String
    Indicates the current status of the Pipeline.
    tables List<Property Map>
    List of streams and sinks used by this pipeline.
    accountId String
    Specifies the public ID of the account.

    Supporting Types

    GetPipelineTable

    Id string
    Unique identifier for the connection (stream or sink).
    Latest int
    Latest available version of the connection.
    Name string
    Name of the connection.
    Type string
    Type of the connection. Available values: "stream", "sink".
    Version int
    Current version of the connection used by this pipeline.
    Id string
    Unique identifier for the connection (stream or sink).
    Latest int
    Latest available version of the connection.
    Name string
    Name of the connection.
    Type string
    Type of the connection. Available values: "stream", "sink".
    Version int
    Current version of the connection used by this pipeline.
    id String
    Unique identifier for the connection (stream or sink).
    latest Integer
    Latest available version of the connection.
    name String
    Name of the connection.
    type String
    Type of the connection. Available values: "stream", "sink".
    version Integer
    Current version of the connection used by this pipeline.
    id string
    Unique identifier for the connection (stream or sink).
    latest number
    Latest available version of the connection.
    name string
    Name of the connection.
    type string
    Type of the connection. Available values: "stream", "sink".
    version number
    Current version of the connection used by this pipeline.
    id str
    Unique identifier for the connection (stream or sink).
    latest int
    Latest available version of the connection.
    name str
    Name of the connection.
    type str
    Type of the connection. Available values: "stream", "sink".
    version int
    Current version of the connection used by this pipeline.
    id String
    Unique identifier for the connection (stream or sink).
    latest Number
    Latest available version of the connection.
    name String
    Name of the connection.
    type String
    Type of the connection. Available values: "stream", "sink".
    version Number
    Current version of the connection used by this pipeline.

    Package Details

    Repository
    Cloudflare pulumi/pulumi-cloudflare
    License
    Apache-2.0
    Notes
    This Pulumi package is based on the cloudflare Terraform Provider.
    cloudflare logo
    Viewing docs for Cloudflare v6.15.0
    published on Saturday, May 2, 2026 by Pulumi
    Schema (JSON)
    pulumi/pulumi-cloudflare
      Try Pulumi Cloud free. Your team will thank you.