Table: steampipecloud_workspace_pipeline

Pipelines allow users to run different kinds of activities in Steampipe Cloud on a schedule.

Important notes:

This table supports optional quals. Queries with optional quals in the where clause are optimised to use Steampipe Cloud filters.

Optional quals are supported for the following columns:

created_at
id
identity_handle
identity_id
pipeline
query_where - Allows use of query filters. For a list of supported columns for pipelines, please see Supported APIs and Columns. Please note that any query filter passed into the query_where qual will be combined with other optional quals.
title
updated_at
workspace_handle
workspace_id

Examples

Basic info

select
  id,
  identity_handle,
  workspace_handle,
  title,
  frequency,
  pipeline,
  args,
  tags,
  last_process_id
from
  steampipecloud_workspace_pipeline;

List pipelines for a specific workspace

select
  id,
  identity_handle,
  workspace_handle,
  title,
  frequency,
  pipeline,
  args,
  tags,
  last_process_id
from
  steampipecloud_workspace_pipeline
where
  workspace_handle = 'dev';

List pipelines of frequency type `interval` for a specific workspace

select
  id,
  identity_handle,
  workspace_handle,
  title,
  frequency,
  pipeline,
  args,
  tags,
  last_process_id
from
  steampipecloud_workspace_pipeline
where
  workspace_handle = 'dev'
  and frequency ->> 'type' = 'interval';

List pipelines for the `AWS Compliance CIS v1.4.0` dashboard created in the last 7 days

select
  id,
  identity_handle,
  workspace_handle,
  title,
  frequency,
  pipeline,
  args,
  tags,
  last_process_id
from
  steampipecloud_workspace_pipeline
where
  args ->> 'resource' = 'aws_compliance.benchmark.cis_v140'
  and created_at >= now() - interval '7 days';

List pipelines for the `AWS Compliance CIS v1.4.0` dashboard created in the last 7 days using query filter

select
  id,
  identity_handle,
  workspace_handle,
  title,
  frequency,
  pipeline,
  args,
  tags,
  last_process_id
from
  steampipecloud_workspace_pipeline
where
  query_where = 'title = ''Scheduled snapshot: CIS v1.4.0'' and created_at >= now() - interval ''7 days''';

Schema for steampipecloud_workspace_pipeline

Name	Type	Operators	Description
_ctx	jsonb		Steampipe context in JSON form, e.g. connection_name.
args	jsonb		Arguments to be passed to the pipeline.
created_at	timestamp with time zone	>, >=, =, <, <=	The time when the pipeline was created.
created_by	jsonb		Information about the user who created the pipeline.
created_by_id	text		The unique identifier of the user who created the pipeline.
frequency	jsonb		The frequency at which the pipeline will be executed.
id	text	=, !=	The unique identifier for the pipeline.
identity_handle	text	=	The handle of the identity.
identity_id	text	=	The unique identifier of the identity to which the pipeline belongs to.
identity_type	text		The type of identity, can be org/user.
last_process	jsonb		Information about the process that was last executed for the pipeline.
last_process_id	text		The unique identifier of the last process that was executed for the pipeline.
pipeline	text	=, !=	The name of the pipeline to be executed.
query_where	text	=	The query where expression to filter pipelines.
tags	jsonb		The tags for the pipeline.
title	text	=, !=	The title of the pipeline.
updated_at	timestamp with time zone	>, >=, =, <, <=	The time when the pipeline was last updated.
updated_by	jsonb		Information about the user who last updated the pipeline.
updated_by_id	text		The unique identifier of the user who last updated the pipeline.
version_id	bigint		The current version ID for the pipeline.
workspace_handle	text	=	The handle of the workspace.
workspace_id	text	=	The unique identifier for the workspace.